summaryrefslogtreecommitdiffstats
path: root/src/main/java/com/att/dmf
diff options
context:
space:
mode:
authorSurendra Reddy Katam <SK00524980@techmahindra.com>2018-09-21 15:23:29 +0530
committerSurendra Reddy Katam <SK00524980@techmahindra.com>2018-09-21 15:23:29 +0530
commit5a9c25120a7efd78e26cd35417ff15aadd8f3b04 (patch)
tree8f0c6a02f797a774ae8170ab0b871ddb7fc36539 /src/main/java/com/att/dmf
parent7a6339681d0930aac1848d2f4770ba0935102708 (diff)
Sonar Major issues
This block of commented-out lines of code should be removed Sonar Link: https://sonar.onap.org/project/issues?assignees=surendraReddy&id=org.onap.dmaap.messagerouter.msgrtr%3Amsgrtr&open=AWU41Wi2wGn37JfbyHxZ&resolved=false&severities=MAJOR Location: src/main/java/com/att/dmf/mr/service/impl/EventsServiceImpl.java Line No-L492 L502 L512 Change-Id: Ia7d862cc50a14b77372257b89a4a3c1cb4b71194 Issue-ID: DMAAP-811 Signed-off-by: Surendra Reddy Katam <SK00524980@techmahindra.com>
Diffstat (limited to 'src/main/java/com/att/dmf')
-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 88c5fd9..5565704 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
@@ -489,7 +489,7 @@ public class EventsServiceImpl implements EventsService {
final LinkedList<Publisher.message> batch = new LinkedList<>();
// final ArrayList<KeyedMessage<String, String>> kms = new
- // ArrayList<KeyedMessage<String, String>>();
+
final ArrayList<ProducerRecord<String, String>> pms = new ArrayList<>();
try {
// for each message...
@@ -499,7 +499,7 @@ public class EventsServiceImpl implements EventsService {
batch.add(m);
// final KeyedMessage<String, String> data = new
// KeyedMessage<String, String>(topic, m.getKey(),
- // m.getMessage());
+
// kms.add(data);
final ProducerRecord<String, String> data = new ProducerRecord<String, String>(topic, m.getKey(),
m.getMessage());
@@ -509,7 +509,7 @@ public class EventsServiceImpl implements EventsService {
final int sizeNow = batch.size();
if (sizeNow > maxEventBatch) {
// ctx.getConfigReader().getfPublisher().sendBatchMessage(topic,
- // kms);
+
// kms.clear();
ctx.getConfigReader().getfPublisher().sendBatchMessageNew(topic, pms);
pms.clear();