From da7f8f0e3f1259d540ba45618e23f1856ae34e9c Mon Sep 17 00:00:00 2001 From: Jorge Hernandez Date: Wed, 31 Jan 2018 23:56:20 -0600 Subject: fix typo when configuring fetch-limit parameter Change-Id: Iea108fe035bea14e2ecd12db68b331dd2d546591 Issue-ID: POLICY-596 Signed-off-by: Jorge Hernandez --- .../org/onap/policy/drools/event/comm/bus/DmaapTopicSourceFactory.java | 3 +-- .../org/onap/policy/drools/event/comm/bus/UebTopicSourceFactory.java | 3 +-- 2 files changed, 2 insertions(+), 4 deletions(-) (limited to 'policy-endpoints/src') diff --git a/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/DmaapTopicSourceFactory.java b/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/DmaapTopicSourceFactory.java index 13808329..d5894d5e 100644 --- a/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/DmaapTopicSourceFactory.java +++ b/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/DmaapTopicSourceFactory.java @@ -158,7 +158,6 @@ public interface DmaapTopicSourceFactory { /** * Instantiates a new DMAAP Topic Source * - * @param uebTopicReaderType Implementation type * @param servers list of servers * @param topic topic name * @@ -445,7 +444,7 @@ class IndexedDmaapTopicSourceFactory implements DmaapTopicSourceFactory { String fetchLimitString = properties.getProperty(PolicyProperties.PROPERTY_DMAAP_SOURCE_TOPICS + "." + topic + - PolicyProperties.PROPERTY_TOPIC_SOURCE_FETCH_TIMEOUT_SUFFIX); + PolicyProperties.PROPERTY_TOPIC_SOURCE_FETCH_LIMIT_SUFFIX); int fetchLimit = DmaapTopicSource.DEFAULT_LIMIT_FETCH; if (fetchLimitString != null && !fetchLimitString.isEmpty()) { try { diff --git a/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/UebTopicSourceFactory.java b/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/UebTopicSourceFactory.java index d2aa6710..d614d100 100644 --- a/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/UebTopicSourceFactory.java +++ b/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/UebTopicSourceFactory.java @@ -96,7 +96,6 @@ public interface UebTopicSourceFactory { /** * Instantiates a new UEB Topic Source * - * @param uebTopicSourceType Implementation type * @param servers list of servers * @param topic topic name * @@ -261,7 +260,7 @@ class IndexedUebTopicSourceFactory implements UebTopicSourceFactory { String fetchLimitString = properties.getProperty(PolicyProperties.PROPERTY_UEB_SOURCE_TOPICS + "." + topic + - PolicyProperties.PROPERTY_TOPIC_SOURCE_FETCH_TIMEOUT_SUFFIX); + PolicyProperties.PROPERTY_TOPIC_SOURCE_FETCH_LIMIT_SUFFIX); int fetchLimit = UebTopicSource.DEFAULT_LIMIT_FETCH; if (fetchLimitString != null && !fetchLimitString.isEmpty()) { try { -- cgit 1.2.3-korg