summaryrefslogtreecommitdiffstats
path: root/dmaap-listener/src/main
diff options
context:
space:
mode:
Diffstat (limited to 'dmaap-listener/src/main')
-rw-r--r--dmaap-listener/src/main/java/org/onap/ccsdk/sli/northbound/dmaapclient/SdncDmaapConsumer.java10
1 files changed, 8 insertions, 2 deletions
diff --git a/dmaap-listener/src/main/java/org/onap/ccsdk/sli/northbound/dmaapclient/SdncDmaapConsumer.java b/dmaap-listener/src/main/java/org/onap/ccsdk/sli/northbound/dmaapclient/SdncDmaapConsumer.java
index a0c55530..a51ea7c8 100644
--- a/dmaap-listener/src/main/java/org/onap/ccsdk/sli/northbound/dmaapclient/SdncDmaapConsumer.java
+++ b/dmaap-listener/src/main/java/org/onap/ccsdk/sli/northbound/dmaapclient/SdncDmaapConsumer.java
@@ -71,19 +71,25 @@ public abstract class SdncDmaapConsumer implements Runnable {
try (FileInputStream in = new FileInputStream(new File(propertiesPath))) {
+ LOG.debug("propertiesPath: " + propertiesPath);
this.properties = (Properties) properties.clone();
this.properties.load(in);
- String timeoutStr = properties.getProperty("timeout");
+
+ String timeoutStr = this.properties.getProperty("timeout");
+ LOG.debug("timeoutStr: " + timeoutStr);
if ((timeoutStr != null) && (timeoutStr.length() > 0)) {
timeout = parseTimeOutValue(timeoutStr);
}
- String fetchPauseStr = properties.getProperty("fetchPause");
+ String fetchPauseStr = this.properties.getProperty("fetchPause");
+ LOG.debug("fetchPause(Str): " + fetchPauseStr);
if ((fetchPauseStr != null) && (fetchPauseStr.length() > 0)) {
fetchPause = parseFetchPause(fetchPauseStr);
}
+ LOG.debug("fetchPause: " + fetchPause);
+
this.consumer = MRClientFactory.createConsumer(propertiesPath);
ready = true;