summaryrefslogtreecommitdiffstats
path: root/src/main/java/com/att
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/com/att')
-rw-r--r--src/main/java/com/att/nsa/mr/test/clients/SimpleExamplePublisher.java6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/main/java/com/att/nsa/mr/test/clients/SimpleExamplePublisher.java b/src/main/java/com/att/nsa/mr/test/clients/SimpleExamplePublisher.java
index 01e770e..8a6c586 100644
--- a/src/main/java/com/att/nsa/mr/test/clients/SimpleExamplePublisher.java
+++ b/src/main/java/com/att/nsa/mr/test/clients/SimpleExamplePublisher.java
@@ -54,12 +54,12 @@ public class SimpleExamplePublisher
// publish some messages
final JSONObject msg1 = new JSONObject ();
msg1.put ( "Name", "Sprint" );
- //msg1.put ( "greeting", "Hello .." );
+
pub.send ( "First cambria messge" );
pub.send ( "MyPartitionKey", msg1.toString () );
final JSONObject msg2 = new JSONObject ();
- //msg2.put ( "mrclient1", System.currentTimeMillis () );
+
// ...
@@ -68,7 +68,7 @@ public class SimpleExamplePublisher
// publisher interface allows the app to get the set of unsent messages. It could
// write them to disk, for example, to try to send them later.
final List<message> stuck = pub.close ( 20, TimeUnit.SECONDS );
- if ( stuck.size () > 0 )
+ if ( stuck.isEmpty() )
{
System.err.println ( stuck.size() + " messages unsent" );
}