summaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/main/java/com/att/dmf/mr/service/impl/EventsServiceImpl.java6
1 files changed, 3 insertions, 3 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 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;