summaryrefslogtreecommitdiffstats
path: root/src/main/java
diff options
context:
space:
mode:
authorSurendra Reddy Katam <SK00524980@techmahindra.com>2018-09-19 12:56:36 +0530
committerSurendra Reddy Katam <SK00524980@techmahindra.com>2018-09-19 12:56:36 +0530
commitdb73ff89232054ee4e42530490cce28636f12516 (patch)
treee845c3ca3418969c06db90dfcbf8e47a7ac267fa /src/main/java
parent6ec5b11a771df8e68719a4043b208cf5497bd553 (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=AWU41WgPwGn37JfbyHtO&resolved=false&severities=MAJOR Location: src/main/java/com/att/dmf/mr/resources/CambriaOutboundEventStream.java Line No-L174 L200 L247 Change-Id: Ia09070d3dde66fe6a506dc0b25c36fffad0e2fcd Issue-ID: DMAAP-796 Signed-off-by: Surendra Reddy Katam <SK00524980@techmahindra.com>
Diffstat (limited to 'src/main/java')
-rw-r--r--src/main/java/com/att/dmf/mr/resources/CambriaOutboundEventStream.java6
1 files changed, 3 insertions, 3 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..539e9c0 100644
--- a/src/main/java/com/att/dmf/mr/resources/CambriaOutboundEventStream.java
+++ b/src/main/java/com/att/dmf/mr/resources/CambriaOutboundEventStream.java
@@ -171,7 +171,7 @@ public class CambriaOutboundEventStream implements StreamWriter {
}
// public Builder atOffset ( int pos )
- // {
+
// fOffset = pos;
// return this;
// }
@@ -197,7 +197,7 @@ public class CambriaOutboundEventStream implements StreamWriter {
fConsumer = builder.fConsumer;
fLimit = builder.fLimit;
fTimeoutMs = builder.fTimeoutMs;
- // fSettings = builder.fSettings;
+
fSent = 0;
fPretty = builder.fPretty;
fWithMeta = builder.fWithMeta;
@@ -244,7 +244,7 @@ public class CambriaOutboundEventStream implements StreamWriter {
* @param msg
* @throws IOException
*/
- // void onMessage(int count, Message msg) throws IOException;
+
void onMessage(int count, String msg, String transId, long offSet) throws IOException, JSONException;
}