1 files changed, 2 insertions, 1 deletions

diff --git a/dcae-analytics-dmaap/src/main/java/org/openecomp/dcae/apod/analytics/dmaap/service/publisher/DMaaPMRPublisherImpl.java b/dcae-analytics-dmaap/src/main/java/org/openecomp/dcae/apod/analytics/dmaap/service/publisher/DMaaPMRPublisherImpl.java
index b3e303e..32e09fa 100644
--- a/dcae-analytics-dmaap/src/main/java/org/openecomp/dcae/apod/analytics/dmaap/service/publisher/DMaaPMRPublisherImpl.java
+++ b/dcae-analytics-dmaap/src/main/java/org/openecomp/dcae/apod/analytics/dmaap/service/publisher/DMaaPMRPublisherImpl.java
@@ -69,8 +69,9 @@ public class DMaaPMRPublisherImpl extends BaseDMaaPMRComponent implements DMaaPM
                                 CloseableHttpClient closeableHttpClient) {

 

         this.publisherConfig = publisherConfig;

+        final int maxBatchSize = publisherConfig.getMaxBatchSize() > 0 ? publisherConfig.getMaxBatchSize() : 1;

         this.publisherQueue = dMaaPMRPublisherQueueFactory.create(

-                publisherConfig.getMaxBatchSize(), publisherConfig.getMaxRecoveryQueueSize());

+                maxBatchSize, publisherConfig.getMaxRecoveryQueueSize());

         this.closeableHttpClient = closeableHttpClient;

         this.publisherUri = createPublisherURI(publisherConfig);

         this.publisherCreationTime = new Date();