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=AWU41Wi2wGn37JfbyHxc&resolved=false&severities=MAJOR
Location:
src/main/java/com/att/dmf/mr/service/impl/EventsServiceImpl.java
Line No-L526 L600 L603
Change-Id: I391aa522b7d288815248c57fd3a58280bc474aee
Issue-ID: DMAAP-812
Signed-off-by: Surendra Reddy Katam <SK00524980@techmahindra.com>
final int sizeNow = batch.size();
if (sizeNow > 0) {
// ctx.getConfigReader().getfPublisher().sendBatchMessage(topic,
final int sizeNow = batch.size();
if (sizeNow > 0) {
// 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();
if (null != evenlen)
maxEventBatch = Long.parseLong(evenlen);
// final long maxEventBatch =
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
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;
final ArrayList<ProducerRecord<String, String>> pms = new ArrayList<ProducerRecord<String, String>>();
Publisher.message m = null;
int messageSequence = 1;