From d43a8024c63c3c2b9c9882ec9ce3d05d20e3e8d0 Mon Sep 17 00:00:00 2001 From: "shashikanth.vh" Date: Tue, 16 Jan 2018 18:53:23 +0530 Subject: 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 --- .../java/org/onap/ccsdk/sli/northbound/dmaapclient/DmaapListener.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 ce099cd6..2be08cb8 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, -- cgit 1.2.3-korg