Sonar Major issues

[dmaap/messagerouter/msgrtr.git] / src / main / java / com / att / dmf / mr / service / impl / EventsServiceImpl.java

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 (file)
--- 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());