diff options
| -rw-r--r-- | src/main/java/com/att/dmf/mr/service/impl/EventsServiceImpl.java | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/main/java/com/att/dmf/mr/service/impl/EventsServiceImpl.java b/src/main/java/com/att/dmf/mr/service/impl/EventsServiceImpl.java index a889103..73a373e 100644 --- a/src/main/java/com/att/dmf/mr/service/impl/EventsServiceImpl.java +++ b/src/main/java/com/att/dmf/mr/service/impl/EventsServiceImpl.java @@ -610,7 +610,7 @@ public class EventsServiceImpl implements EventsService { SimpleDateFormat sdf = new SimpleDateFormat("dd/MM/yyyy HH:mm:ss.SS"); // LOG.warn("Batch Start Id: " + - // Utils.getFromattedBatchSequenceId(batchId)); + try { // for each message... batchId = DMaaPContext.getBatchID(); @@ -620,13 +620,13 @@ public class EventsServiceImpl implements EventsService { while ((m = events.next()) != null) { // LOG.warn("Batch Start Id: " + - // Utils.getFromattedBatchSequenceId(batchId)); + addTransactionDetailsToMessage(m, topic, ctx.getRequest(), requestTime, messageSequence, batchId, transactionEnabled); messageSequence++; - // add the message to the batch + batch.add(m); responseTransactionId = m.getLogDetails().getTransactionId(); @@ -636,7 +636,7 @@ public class EventsServiceImpl implements EventsService { jsonObject.put("transactionId", responseTransactionId); // final KeyedMessage<String, String> data = new // KeyedMessage<String, String>(topic, m.getKey(), - // jsonObject.toString()); + // kms.add(data); final ProducerRecord<String, String> data = new ProducerRecord<String, String>(topic, m.getKey(), m.getMessage()); |