summaryrefslogtreecommitdiffstats
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
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>
-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 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,