From 3cc24f44c6ed20438aa8c7160c172fc42b883845 Mon Sep 17 00:00:00 2001 From: "Singla, Rajiv (rs153v)" Date: Thu, 5 Oct 2017 13:15:24 -0400 Subject: TCA:Updated eventName logging messages Change-Id: Ic4d2f099d8d9f98777ece9aec8d53ae05b051bbc Signed-off-by: Singla, Rajiv (rs153v) Issue-Id: DCAEGEN2-123 --- .../apod/analytics/dmaap/service/publisher/DMaaPMRPublisherImpl.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) (limited to 'dcae-analytics-dmaap') 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(); -- cgit 1.2.3-korg