fix typo when configuring fetch-limit parameter

Change-Id: Iea108fe035bea14e2ecd12db68b331dd2d546591
Issue-ID: POLICY-596
Signed-off-by: Jorge Hernandez <jh1730@att.com>

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 1380832..d5894d5 100644 (file)
--- 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 d2aa671..d614d10 100644 (file)
--- 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 {