aboutsummaryrefslogtreecommitdiffstats
path: root/src/main/java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java')
-rw-r--r--src/main/java/com/att/nsa/mr/client/impl/MRBatchPublisher.java2
1 files changed, 1 insertions, 1 deletions
diff --git a/src/main/java/com/att/nsa/mr/client/impl/MRBatchPublisher.java b/src/main/java/com/att/nsa/mr/client/impl/MRBatchPublisher.java
index 02c3c69..1310986 100644
--- a/src/main/java/com/att/nsa/mr/client/impl/MRBatchPublisher.java
+++ b/src/main/java/com/att/nsa/mr/client/impl/MRBatchPublisher.java
@@ -158,7 +158,7 @@ public class MRBatchPublisher implements MRBatchingPublisher
try
{
final List<message> remains = close ( Long.MAX_VALUE, TimeUnit.MILLISECONDS );
- if ( remains.size() > 0 )
+ if ( remains.isEmpty() )
{
fLog.warn ( "Closing publisher with " + remains.size() + " messages unsent. "
+ "(Consider using the alternate close method to capture unsent messages in this case.)" );