diff options
| author |   Jorge Hernandez <jh1730@att.com> | 2018-01-31 23:56:20 -0600 |
|---|---|---|
| committer | Jorge Hernandez <jh1730@att.com> | 2018-01-31 23:57:29 -0600 |
| commit | da7f8f0e3f1259d540ba45618e23f1856ae34e9c (patch) | |
| tree | 151ddab50d82271b347f9583f2e8652adcb4bde4 /policy-endpoints | |
| parent | 9e2820c5820b3904e03cb7a4cb4292e864b1ca2b (diff) | |
fix typo when configuring fetch-limit parameter
Change-Id: Iea108fe035bea14e2ecd12db68b331dd2d546591
Issue-ID: POLICY-596
Signed-off-by: Jorge Hernandez <jh1730@att.com>
Diffstat (limited to 'policy-endpoints')
2 files changed, 2 insertions, 4 deletions
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 { |