From: shashikanth.vh <shashikanth.vh@huawei.com>
Date: Tue, 16 Jan 2018 13:23:23 +0000 (+0530)
Subject: Fixed DmaapListener multiple consumer thread issue
X-Git-Tag: 1.0.4~7^2~163^2
X-Git-Url: https://gerrit.onap.org/r/gitweb?a=commitdiff_plain;h=d43a8024c63c3c2b9c9882ec9ce3d05d20e3e8d0;p=ccsdk%2Fsli.git

Fixed DmaapListener multiple consumer thread issue

DmaapListener handleSubscriptions method returns after creating
consumer thread for first subscription string, issue is fixed by
removing return.
https://jira.onap.org/browse/CCSDK-173

Issue-ID: CCSDK-173
Change-Id: I796b000b22762cda0a4f4fa929d5e2aabdcc7e8b
Signed-off-by: shashikanth.vh <shashikanth.vh@huawei.com>
---

diff --git a/dmaap-listener/src/main/java/org/onap/ccsdk/sli/northbound/dmaapclient/DmaapListener.java b/dmaap-listener/src/main/java/org/onap/ccsdk/sli/northbound/dmaapclient/DmaapListener.java
index ce099cd64..2be08cb8b 100644
--- a/dmaap-listener/src/main/java/org/onap/ccsdk/sli/northbound/dmaapclient/DmaapListener.java
+++ b/dmaap-listener/src/main/java/org/onap/ccsdk/sli/northbound/dmaapclient/DmaapListener.java
@@ -142,11 +142,11 @@ public class DmaapListener {
             }
 
             if (consumerClass != null) {
-                return handleConsumerClass(consumerClass, consumerClassName, propertyPath,
+                handleConsumerClass(consumerClass, consumerClassName, propertyPath,
                     properties, consumers);
             }
         }
-        return false;
+        return !consumers.isEmpty();
     }
 
     private static boolean handleConsumerClass(Class<?> consumerClass, String consumerClassName, String propertyPath,