aboutsummaryrefslogtreecommitdiffstats
path: root/dcae-analytics-dmaap/src
diff options
context:
space:
mode:
authorSingla, Rajiv (rs153v) <rs153v@att.com>2017-10-05 13:15:24 -0400
committerSingla, Rajiv (rs153v) <rs153v@att.com>2017-10-05 13:19:04 -0400
commit3cc24f44c6ed20438aa8c7160c172fc42b883845 (patch)
treea723d258706c8cba6fd2f28e92a277c52688fbfd /dcae-analytics-dmaap/src
parentbff77d5302988e01a82bb3b224313cbb12123e5c (diff)
TCA:Updated eventName logging messages
Change-Id: Ic4d2f099d8d9f98777ece9aec8d53ae05b051bbc Signed-off-by: Singla, Rajiv (rs153v) <rs153v@att.com> Issue-Id: DCAEGEN2-123
Diffstat (limited to 'dcae-analytics-dmaap/src')
-rw-r--r--dcae-analytics-dmaap/src/main/java/org/openecomp/dcae/apod/analytics/dmaap/service/publisher/DMaaPMRPublisherImpl.java3
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();