aboutsummaryrefslogtreecommitdiffstats
path: root/dmaap-listener
diff options
context:
space:
mode:
authorDan Timoney <dt5972@att.com>2018-02-28 15:33:10 +0000
committerGerrit Code Review <gerrit@onap.org>2018-02-28 15:33:10 +0000
commit4bab4f2255a19f54aa3c18f5b51b2715f085d83c (patch)
tree037978fcf8dc08cd82e6f62f1a2ae495d5063b64 /dmaap-listener
parent10b6a72f544dd1331e9dba53e77c61deaafbd19f (diff)
parentd43a8024c63c3c2b9c9882ec9ce3d05d20e3e8d0 (diff)
Merge "Fixed DmaapListener multiple consumer thread issue"
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,