Merge "Fixed DmaapListener multiple consumer thread issue"
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 ce099cd..2be08cb 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 @@
}
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,