diff --git a/provider/indexer-ibm/src/main/java/org/opengroup/osdu/indexer/ibm/util/IndexerQueueTaskBuilderIbm.java b/provider/indexer-ibm/src/main/java/org/opengroup/osdu/indexer/ibm/util/IndexerQueueTaskBuilderIbm.java index e7d21becb4ccd57f7b62b6bc63c85acf71769424..e9ecc970fa86688f9440018ca8314a21b349bde2 100644 --- a/provider/indexer-ibm/src/main/java/org/opengroup/osdu/indexer/ibm/util/IndexerQueueTaskBuilderIbm.java +++ b/provider/indexer-ibm/src/main/java/org/opengroup/osdu/indexer/ibm/util/IndexerQueueTaskBuilderIbm.java @@ -40,7 +40,6 @@ public class IndexerQueueTaskBuilderIbm extends IndexerQueueTaskBuilder { private void createTask(String payload, DpsHeaders headers) { try { - System.out.println("Payload recived :"+payload); RecordChangedMessages receivedPayload = gson.fromJson(payload, RecordChangedMessages.class); Map<String, String> attributes = receivedPayload.getAttributes(); @@ -59,8 +58,8 @@ public class IndexerQueueTaskBuilderIbm extends IndexerQueueTaskBuilder { mq.sendMessage("DLQ", gson.toJson(receivedPayload)); }*/ - mq.sendMessage(IMessageFactory.DEFAULT_QUEUE_NAME, gson.toJson(receivedPayload), 20000); logger.info("Message send back to queue : "+receivedPayload); + mq.sendMessage(IMessageFactory.DEFAULT_QUEUE_NAME, gson.toJson(receivedPayload)); } catch (JsonSyntaxException e) { logger.error("JsonSyntaxException in IndexerQueueTaskBuilderIbm "+e.toString()); e.printStackTrace();