X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fmr%2Fclient%2Fimpl%2FMRSimplerBatchPublisher.java;h=8f2a66e156f976f060baf5405456d73178569b52;hb=4e6f8ad82b553c3a0d727a186a615a6addf484a3;hp=d9076a49bb2cbbd28843d74bb30d5ad1e56afbe6;hpb=050efb3743cc127f2f3a3298d6731dd926994cd2;p=dmaap%2Fmessagerouter%2Fdmaapclient.git

diff --git a/src/main/java/org/onap/dmaap/mr/client/impl/MRSimplerBatchPublisher.java b/src/main/java/org/onap/dmaap/mr/client/impl/MRSimplerBatchPublisher.java
index d9076a4..8f2a66e 100644
--- a/src/main/java/org/onap/dmaap/mr/client/impl/MRSimplerBatchPublisher.java
+++ b/src/main/java/org/onap/dmaap/mr/client/impl/MRSimplerBatchPublisher.java
@@ -131,6 +131,7 @@ public class MRSimplerBatchPublisher extends MRBaseClient implements MRBatchingP
 		private String fTransportype;	
 		private String fTopic;
 		private int fMaxBatchSize = 100;
+		
 		private long fMaxBatchAgeMs = 1000;
 		private boolean fCompress = false;
 		private int threadOccuranceTime = 50;
@@ -233,7 +234,7 @@ public class MRSimplerBatchPublisher extends MRBaseClient implements MRBatchingP
 
 	private synchronized boolean shouldSendNow() {
 		boolean shouldSend = false;
-		if (fPending.isEmpty()) {
+		if (fPending.size()>0) {
 			final long nowMs = Clock.now();
 
 			shouldSend = (fPending.size() >= fMaxBatchSize);