diff options
author | rama-huawei <rama.subba.reddy.s@huawei.com> | 2017-09-18 19:01:30 +0530 |
---|---|---|
committer | rama-huawei <rama.subba.reddy.s@huawei.com> | 2017-09-18 19:01:30 +0530 |
commit | 2ffe9c3ae469146421e01fd4cef138a3c980ca4e (patch) | |
tree | 7cc5a545a0354e0958dd22b52a2a4ef93f1c3015 /src/main/java | |
parent | cdfeee0cdb522597b62c080ff018cd2c40c67295 (diff) |
Fix for Sonar major issues
DCAEGEN2-93
Change-Id: Iee697aff3e2ce31e5e3510c25812c33a8a99c7ca
Signed-off-by: rama-huawei <rama.subba.reddy.s@huawei.com>
Diffstat (limited to 'src/main/java')
-rw-r--r-- | src/main/java/com/att/nsa/mr/test/clients/SampleConsumer.java | 18 |
1 files changed, 8 insertions, 10 deletions
diff --git a/src/main/java/com/att/nsa/mr/test/clients/SampleConsumer.java b/src/main/java/com/att/nsa/mr/test/clients/SampleConsumer.java index 5e6825c..eac8b7f 100644 --- a/src/main/java/com/att/nsa/mr/test/clients/SampleConsumer.java +++ b/src/main/java/com/att/nsa/mr/test/clients/SampleConsumer.java @@ -21,7 +21,6 @@ *******************************************************************************/ package com.att.nsa.mr.test.clients; -import java.io.IOException; import java.util.LinkedList; import org.slf4j.Logger; @@ -31,12 +30,14 @@ import com.att.nsa.mr.client.MRClientFactory; import com.att.nsa.mr.client.MRConsumer; public class SampleConsumer { + private SampleConsumer() { + } public static void main ( String[] args ) { - final Logger LOG = LoggerFactory.getLogger(SampleConsumer.class); + final Logger log = LoggerFactory.getLogger(SampleConsumer.class); - LOG.info("Sample Consumer Class executing"); + log.info("Sample Consumer Class executing"); final String topic = "com.att.app.dmaap.mr.testingTopic"; final String url = ( args.length > 1 ? args[1] : "localhost:8181" ); final String group = ( args.length > 2 ? args[2] :"grp" ); @@ -61,8 +62,7 @@ public class SampleConsumer { { for ( String msg : cc.fetch () ) { - //System.out.println ( "" + (++count) + ": " + msg ); - LOG.info ( "" + (++count) + ": " + msg ); + log.info ( "" + (++count) + ": " + msg ); } if ( count > nextReport ) @@ -73,16 +73,14 @@ public class SampleConsumer { final long elapsedMs = endMs - startMs; final double elapsedSec = elapsedMs / 1000.0; final double eps = count / elapsedSec; - //System.out.println ( "Consumed " + count + " in " + elapsedSec + "; " + eps + " eps" ); - LOG.info ( "Consumed " + count + " in " + elapsedSec + "; " + eps + " eps" ); + log.info ( "Consumed " + count + " in " + elapsedSec + "; " + eps + " eps" ); } - LOG.info ( "" + (++count) + ": consumed message" ); + log.info ( "" + (++count) + ": consumed message" ); } } catch ( Exception x ) { - System.err.println ( x.getClass().getName () + ": " + x.getMessage () ); - LOG.error("exception: ", x); + log.error( x.getClass().getName () + ": " + x.getMessage () ); } } } |