X-Git-Url: https://gerrit.onap.org/r/gitweb?p=dmaap%2Fmessagerouter%2Fmsgrtr.git;a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fcom%2Fatt%2Fdmf%2Fmr%2Fservice%2Fimpl%2FEventsServiceImpl.java;h=a88910379e391b8ae3eff5e4540cf9d1d6d59db4;hp=55657042a11017dbad55ba197d96f137f64423f4;hb=51659cfd123fab4c7a5ce25cc300182c8a9a0d20;hpb=5a9c25120a7efd78e26cd35417ff15aadd8f3b04

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 5565704..a889103 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
@@ -523,7 +523,7 @@ public class EventsServiceImpl implements EventsService {
 			final int sizeNow = batch.size();
 			if (sizeNow > 0) {
 				// ctx.getConfigReader().getfPublisher().sendBatchMessage(topic,
-				// kms);
+			
 				// kms.clear();
 				ctx.getConfigReader().getfPublisher().sendBatchMessageNew(topic, pms);
 				pms.clear();
@@ -597,10 +597,10 @@ public class EventsServiceImpl implements EventsService {
 		if (null != evenlen)
 			maxEventBatch = Long.parseLong(evenlen);
 		// final long maxEventBatch =
-		// ctx.getConfigReader().getSettings().getLong(BATCH_LENGTH, 1024 * 16);
+		
 		final LinkedList<Publisher.message> batch = new LinkedList<Publisher.message>();
 		// final ArrayList<KeyedMessage<String, String>> kms = new
-		// ArrayList<KeyedMessage<String, String>>();
+		
 		final ArrayList<ProducerRecord<String, String>> pms = new ArrayList<ProducerRecord<String, String>>();
 		Publisher.message m = null;
 		int messageSequence = 1;