summaryrefslogtreecommitdiffstats
path: root/policy-endpoints/src
diff options
context:
space:
mode:
authorJorge Hernandez <jh1730@att.com>2018-01-31 23:56:20 -0600
committerJorge Hernandez <jh1730@att.com>2018-01-31 23:57:29 -0600
commitda7f8f0e3f1259d540ba45618e23f1856ae34e9c (patch)
tree151ddab50d82271b347f9583f2e8652adcb4bde4 /policy-endpoints/src
parent9e2820c5820b3904e03cb7a4cb4292e864b1ca2b (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/src')
-rw-r--r--policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/DmaapTopicSourceFactory.java3
-rw-r--r--policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/UebTopicSourceFactory.java3
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 {