From 4e6f8ad82b553c3a0d727a186a615a6addf484a3 Mon Sep 17 00:00:00 2001 From: su622b Date: Tue, 26 Nov 2019 15:31:44 -0500 Subject: fix the code that determines when to publish batch Issue-ID: DMAAP-1345 Change-Id: Ic297507a4faed4e109445f7a1fcb16435a1dc682 Signed-off-by: su622b --- .../java/org/onap/dmaap/mr/client/impl/MRSimplerBatchPublisher.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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); -- cgit 1.2.3-korg