summaryrefslogtreecommitdiffstats
path: root/src/main
diff options
context:
space:
mode:
authorSurendra Reddy Katam <SK00524980@techmahindra.com>2018-09-18 17:51:13 +0530
committerSurendra Reddy Katam <SK00524980@techmahindra.com>2018-09-18 17:51:13 +0530
commit0c6830de3dce50a97b576e62af0d44f1ae068d45 (patch)
tree8b49520baa7f56216c25527d1f85873c617b6116 /src/main
parent417dd58bd32b95c000c7802e6b6bee8611962f46 (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=AWU41WgPwGn37JfbyHtK&resolved=false&severities=MAJOR Location: src/main/java/com/att/dmf/mr/resources/CambriaOutboundEventStream.java Line No-L48 L91 L100 L107 Change-Id: Ic73990ff2a9a85fee7c15b21694a42b9aece2d31 Issue-ID: DMAAP-788 Signed-off-by: Surendra Reddy Katam <SK00524980@techmahindra.com>
Diffstat (limited to 'src/main')
-rw-r--r--src/main/java/com/att/dmf/mr/resources/CambriaOutboundEventStream.java8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/main/java/com/att/dmf/mr/resources/CambriaOutboundEventStream.java b/src/main/java/com/att/dmf/mr/resources/CambriaOutboundEventStream.java
index 837c956..cde7720 100644
--- a/src/main/java/com/att/dmf/mr/resources/CambriaOutboundEventStream.java
+++ b/src/main/java/com/att/dmf/mr/resources/CambriaOutboundEventStream.java
@@ -45,7 +45,7 @@ import com.att.dmf.mr.utils.DMaaPResponseBuilder.StreamWriter;
import com.att.dmf.mr.utils.Utils;
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFManager;
-//import com.att.nsa.drumlin.till.nv.rrNvReadable;
+
/*import com.att.sa.highlandPark.config.HpConfigContext;
import com.att.sa.highlandPark.config.HpReaderException;
import com.att.sa.highlandPark.events.HpJsonEvent;
@@ -88,7 +88,7 @@ public class CambriaOutboundEventStream implements StreamWriter {
private boolean fWithMeta;
ArrayList<Consumer> fKafkaConsumerList;
- // private int fOffset;
+
/**
* constructor it initializes all the consumer parameters
*
@@ -97,14 +97,14 @@ public class CambriaOutboundEventStream implements StreamWriter {
*/
public Builder(Consumer c) {
this.fConsumer = c;
- // this.fSettings = settings;
+
fLimit = CambriaConstants.kNoTimeout;
fTimeoutMs = CambriaConstants.kNoLimit;
fTopicFilter = CambriaConstants.kNoFilter;
fPretty = false;
fWithMeta = false;
- //this.fKafkaConsumerList = consList;
+
// fOffset = CambriaEvents.kNextOffset;
}