diff options
Diffstat (limited to 'src/main/java/com/att/nsa/mr/test')
4 files changed, 30 insertions, 16 deletions
diff --git a/src/main/java/com/att/nsa/mr/test/clients/ConsolePublisher.java b/src/main/java/com/att/nsa/mr/test/clients/ConsolePublisher.java index 2294d7b..61aa836 100644 --- a/src/main/java/com/att/nsa/mr/test/clients/ConsolePublisher.java +++ b/src/main/java/com/att/nsa/mr/test/clients/ConsolePublisher.java @@ -29,6 +29,9 @@ import java.util.List; import java.util.UUID; import java.util.concurrent.TimeUnit; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + import com.att.nsa.mr.client.MRBatchingPublisher; import com.att.nsa.mr.client.MRClientFactory; import com.att.nsa.mr.client.MRPublisher.message; @@ -39,16 +42,20 @@ import com.att.nsa.mr.client.MRPublisher.message; */ public class ConsolePublisher { + + private static final Logger logger = LoggerFactory.getLogger(ConsolePublisher.class); + private ConsolePublisher() { + } public static void main ( String[] args ) throws IOException //throws IOException, InterruptedException { // read the hosts(s) from the command line - final String hosts = ( args.length > 0 ? args[0] : "aaa.it.att.com,bbb.it.att.com,ccc.it.att.com" ); + final String hosts = args.length > 0 ? args[0] : "aaa.it.att.com,bbb.it.att.com,ccc.it.att.com"; // read the topic name from the command line - final String topic = ( args.length > 1 ? args[1] : "TEST-TOPIC" ); + final String topic = args.length > 1 ? args[1] : "TEST-TOPIC"; // read the topic name from the command line - final String partition = ( args.length > 2 ? args[2] : UUID.randomUUID ().toString () ); + final String partition = args.length > 2 ? args[2] : UUID.randomUUID ().toString (); // set up some batch limits and the compression flag final int maxBatchSize = 100; @@ -76,11 +83,11 @@ public class ConsolePublisher } catch ( InterruptedException e ) { - System.err.println ( "Send on close interrupted." ); + logger.error( "Send on close interrupted." ); } for ( message m : leftovers ) { - System.err.println ( "Unsent message: " + m.fMsg ); + logger.error( "Unsent message: " + m.fMsg ); } } } 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 8e1c0e0..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,15 +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( x.getClass().getName () + ": " + x.getMessage () ); } } } diff --git a/src/main/java/com/att/nsa/mr/test/clients/SimpleExampleConsumer.java b/src/main/java/com/att/nsa/mr/test/clients/SimpleExampleConsumer.java index 3a131a0..5ae36d2 100644 --- a/src/main/java/com/att/nsa/mr/test/clients/SimpleExampleConsumer.java +++ b/src/main/java/com/att/nsa/mr/test/clients/SimpleExampleConsumer.java @@ -22,13 +22,14 @@ package com.att.nsa.mr.test.clients; - - import java.io.File; import java.io.FileReader; import java.io.FileWriter; import java.util.Properties; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + import com.att.nsa.mr.client.MRClientFactory; import com.att.nsa.mr.client.MRConsumer; @@ -40,6 +41,7 @@ public class SimpleExampleConsumer static FileReader routeReader=null; public static void main ( String[] args ) { + final Logger LOG = LoggerFactory.getLogger(SimpleExampleConsumer.class); long count = 0; long nextReport = 5000; @@ -81,6 +83,7 @@ public class SimpleExampleConsumer catch ( Exception x ) { System.err.println ( x.getClass().getName () + ": " + x.getMessage () ); + LOG.error("exception: ", x); } } } diff --git a/src/main/java/com/att/nsa/mr/test/clients/SimpleExampleConsumerWithReturnResponse.java b/src/main/java/com/att/nsa/mr/test/clients/SimpleExampleConsumerWithReturnResponse.java index b3c167b..433ab9f 100644 --- a/src/main/java/com/att/nsa/mr/test/clients/SimpleExampleConsumerWithReturnResponse.java +++ b/src/main/java/com/att/nsa/mr/test/clients/SimpleExampleConsumerWithReturnResponse.java @@ -26,12 +26,16 @@ import java.io.FileReader; import java.io.FileWriter; import java.util.Properties; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + import com.att.nsa.mr.client.MRClientFactory; import com.att.nsa.mr.client.MRConsumer; import com.att.nsa.mr.client.response.MRConsumerResponse; public class SimpleExampleConsumerWithReturnResponse { + private static final Logger LOG = LoggerFactory.getLogger(SimpleExampleConsumerWithReturnResponse.class); static FileWriter routeWriter= null; static Properties props=null; @@ -84,6 +88,7 @@ public class SimpleExampleConsumerWithReturnResponse { catch ( Exception x ) { System.err.println ( x.getClass().getName () + ": " + x.getMessage () ); + LOG.error("exception: ", x); } } |