diff options
author | Ram Koya <rk541m@att.com> | 2018-09-20 15:26:51 +0000 |
---|---|---|
committer | Gerrit Code Review <gerrit@onap.org> | 2018-09-20 15:26:51 +0000 |
commit | 7a6339681d0930aac1848d2f4770ba0935102708 (patch) | |
tree | 9c6f5c1c7322f76feb518b9951dac2dd72bef1cf /src/main/java | |
parent | 17a3af28994f91f6ebca3df89e43a29ccc4482ff (diff) | |
parent | 0c6830de3dce50a97b576e62af0d44f1ae068d45 (diff) |
Merge "Sonar Major issues"
Diffstat (limited to 'src/main/java')
-rw-r--r-- | src/main/java/com/att/dmf/mr/resources/CambriaOutboundEventStream.java | 8 |
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 9ef2139..97d1fa5 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; } |