diff options
| author |   Dan Timoney <dt5972@att.com> | 2018-02-28 15:33:10 +0000 |
|---|---|---|
| committer |   Gerrit Code Review <gerrit@onap.org> | 2018-02-28 15:33:10 +0000 |
| commit | 4bab4f2255a19f54aa3c18f5b51b2715f085d83c (patch) | |
| tree | 037978fcf8dc08cd82e6f62f1a2ae495d5063b64 | |
| parent | 10b6a72f544dd1331e9dba53e77c61deaafbd19f (diff) | |
| parent | d43a8024c63c3c2b9c9882ec9ce3d05d20e3e8d0 (diff) | |
Merge "Fixed DmaapListener multiple consumer thread issue"
| -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, |