diff options
Diffstat (limited to 'src/main/java')
| -rw-r--r-- | src/main/java/com/att/nsa/mr/client/impl/MRBatchPublisher.java | 2 |
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.)" ); |