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=AWYBFCTAligbnTmNJUX3&resolved=false&severities=MAJOR
Location:
src/main/java/org/onap/dmaap/dmf/mr/service/impl/EventsServiceImpl.java
Line No-L640 L653 L684 L701 L730 L859
Change-Id: I7369cfb186a2c906359d53b7c92b035039952280
Issue-ID: DMAAP-956
Signed-off-by: Surendra Reddy Katam <SK00524980@techmahindra.com>
// final KeyedMessage<String, String> data = new
// KeyedMessage<String, String>(topic, m.getKey(),
// final KeyedMessage<String, String> data = new
// KeyedMessage<String, String>(topic, m.getKey(),
final ProducerRecord<String, String> data = new ProducerRecord<String, String>(topic, m.getKey(),
m.getMessage());
final ProducerRecord<String, String> data = new ProducerRecord<String, String>(topic, m.getKey(),
m.getMessage());
+ batchId + "]");
try {
// ctx.getConfigReader().getfPublisher().sendBatchMessage(topic,
+ batchId + "]");
try {
// ctx.getConfigReader().getfPublisher().sendBatchMessage(topic,
ctx.getConfigReader().getfPublisher().sendBatchMessageNew(topic, pms);
// transactionLogs(batch);
for (message msg : batch) {
ctx.getConfigReader().getfPublisher().sendBatchMessageNew(topic, pms);
// transactionLogs(batch);
for (message msg : batch) {
metricsSet.publishTick(sizeNow);
publishBatchCount = sizeNow;
count += sizeNow;
metricsSet.publishTick(sizeNow);
publishBatchCount = sizeNow;
count += sizeNow;
String endTime = sdf.format(new Date());
LOG.info("Batch End Details:[serverIp=" + ctx.getRequest().getLocalAddr() + ",Batch End Id="
+ batchId + ",Batch Total=" + publishBatchCount + ",Batch Start Time=" + startTime
String endTime = sdf.format(new Date());
LOG.info("Batch End Details:[serverIp=" + ctx.getRequest().getLocalAddr() + ",Batch End Id="
+ batchId + ",Batch Total=" + publishBatchCount + ",Batch Start Time=" + startTime
+ batchId + "]");
try {
// ctx.getConfigReader().getfPublisher().sendBatchMessage(topic,
+ batchId + "]");
try {
// ctx.getConfigReader().getfPublisher().sendBatchMessage(topic,
ctx.getConfigReader().getfPublisher().sendBatchMessageNew(topic, pms);
ctx.getConfigReader().getfPublisher().sendBatchMessageNew(topic, pms);
- // transactionLogs(batch);
for (message msg : batch) {
LogDetails logDetails = msg.getLogDetails();
LOG.info("Publisher Log Details : " + logDetails.getPublisherLogDetails());
for (message msg : batch) {
LogDetails logDetails = msg.getLogDetails();
LOG.info("Publisher Log Details : " + logDetails.getPublisherLogDetails());
pms.clear();
metricsSet.publishTick(sizeNow);
count += sizeNow;
pms.clear();
metricsSet.publishTick(sizeNow);
count += sizeNow;
String endTime = sdf.format(new Date());
publishBatchCount = sizeNow;
LOG.info("Batch End Details:[serverIp=" + ctx.getRequest().getLocalAddr() + ",Batch End Id=" + batchId
String endTime = sdf.format(new Date());
publishBatchCount = sizeNow;
LOG.info("Batch End Details:[serverIp=" + ctx.getRequest().getLocalAddr() + ",Batch End Id=" + batchId
- /*
- * public String getMetricsTopic() { return metricsTopic; }
- *
- * public void setMetricsTopic(String metricsTopic) { this.metricsTopic =
- * metricsTopic; }
- */