diff options
| author |   shashikanth.vh <shashikanth.vh@huawei.com> | 2018-01-16 18:53:23 +0530 |
|---|---|---|
| committer | Shashikanth VH <shashikanth.vh@huawei.com> | 2018-01-18 05:09:22 +0000 |
| commit | d43a8024c63c3c2b9c9882ec9ce3d05d20e3e8d0 (patch) | |
| tree | 12d7fe8989e617905894c4e3ae50723e27691bb0 | |
| parent | 4b3d9579edc94c174fd942c488f6efa57c9e24b7 (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.java | 4 |
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, |