summaryrefslogtreecommitdiffstats
path: root/src/main/java/com/att
diff options
context:
space:
mode:
authorSurendra Reddy Katam <SK00524980@techmahindra.com>2018-09-21 16:45:49 +0530
committerSurendra Reddy Katam <SK00524980@techmahindra.com>2018-09-21 16:45:49 +0530
commita35521d1390b109e754aaab5b2d45d427a070165 (patch)
tree5ab349b90e1c74c0a320cb034d821526f5dd0e79 /src/main/java/com/att
parent51659cfd123fab4c7a5ce25cc300182c8a9a0d20 (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=AWU41Wi2wGn37JfbyHxf&resolved=false&severities=MAJOR Location: src/main/java/com/att/dmf/mr/service/impl/EventsServiceImpl.java Line No:L613 L623 L639 Change-Id: I0c880e87896a94a4bf15df439f03b48cee083f71 Issue-ID: DMAAP-813 Signed-off-by: Surendra Reddy Katam <SK00524980@techmahindra.com>
Diffstat (limited to 'src/main/java/com/att')
-rw-r--r--src/main/java/com/att/dmf/mr/service/impl/EventsServiceImpl.java8
1 files changed, 4 insertions, 4 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 a889103..73a373e 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
@@ -610,7 +610,7 @@ public class EventsServiceImpl implements EventsService {
SimpleDateFormat sdf = new SimpleDateFormat("dd/MM/yyyy HH:mm:ss.SS");
// LOG.warn("Batch Start Id: " +
- // Utils.getFromattedBatchSequenceId(batchId));
+
try {
// for each message...
batchId = DMaaPContext.getBatchID();
@@ -620,13 +620,13 @@ public class EventsServiceImpl implements EventsService {
while ((m = events.next()) != null) {
// LOG.warn("Batch Start Id: " +
- // Utils.getFromattedBatchSequenceId(batchId));
+
addTransactionDetailsToMessage(m, topic, ctx.getRequest(), requestTime, messageSequence, batchId,
transactionEnabled);
messageSequence++;
- // add the message to the batch
+
batch.add(m);
responseTransactionId = m.getLogDetails().getTransactionId();
@@ -636,7 +636,7 @@ public class EventsServiceImpl implements EventsService {
jsonObject.put("transactionId", responseTransactionId);
// final KeyedMessage<String, String> data = new
// KeyedMessage<String, String>(topic, m.getKey(),
- // jsonObject.toString());
+
// kms.add(data);
final ProducerRecord<String, String> data = new ProducerRecord<String, String>(topic, m.getKey(),
m.getMessage());