aboutsummaryrefslogtreecommitdiffstats
path: root/dmaap-listener
diff options
context:
space:
mode:
authorshashikanth.vh <shashikanth.vh@huawei.com>2018-01-16 18:53:23 +0530
committerShashikanth VH <shashikanth.vh@huawei.com>2018-01-18 05:09:22 +0000
commitd43a8024c63c3c2b9c9882ec9ce3d05d20e3e8d0 (patch)
tree12d7fe8989e617905894c4e3ae50723e27691bb0 /dmaap-listener
parent4b3d9579edc94c174fd942c488f6efa57c9e24b7 (diff)
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>
Diffstat (limited to 'dmaap-listener')
-rw-r--r--dmaap-listener/src/main/java/org/onap/ccsdk/sli/northbound/dmaapclient/DmaapListener.java4
1 files 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,