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>
final LinkedList<Publisher.message> batch = new LinkedList<>();
// final ArrayList<KeyedMessage<String, String>> kms = new
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...
final ArrayList<ProducerRecord<String, String>> pms = new ArrayList<>();
try {
// for each message...
batch.add(m);
// final KeyedMessage<String, String> data = new
// KeyedMessage<String, String>(topic, m.getKey(),
batch.add(m);
// final KeyedMessage<String, String> data = new
// KeyedMessage<String, String>(topic, m.getKey(),
// kms.add(data);
final ProducerRecord<String, String> data = new ProducerRecord<String, String>(topic, m.getKey(),
m.getMessage());
// kms.add(data);
final ProducerRecord<String, String> data = new ProducerRecord<String, String>(topic, m.getKey(),
m.getMessage());
final int sizeNow = batch.size();
if (sizeNow > maxEventBatch) {
// ctx.getConfigReader().getfPublisher().sendBatchMessage(topic,
final int sizeNow = batch.size();
if (sizeNow > maxEventBatch) {
// ctx.getConfigReader().getfPublisher().sendBatchMessage(topic,
// kms.clear();
ctx.getConfigReader().getfPublisher().sendBatchMessageNew(topic, pms);
pms.clear();
// kms.clear();
ctx.getConfigReader().getfPublisher().sendBatchMessageNew(topic, pms);
pms.clear();