summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-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 4701a1f..cf42907 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
@@ -319,7 +319,7 @@ public class MRBatchPublisher implements MRBatchingPublisher
fReadLock.lock ();
try
{
- if ( fNextBatch.size () > 0 )
+ if ( fNextBatch.isEmpty() )
{
final long nowMs = System.currentTimeMillis ();
shouldSend = ( force || fNextBatch.size() >= fMaxBatchSize );