diff options
| author |   Brian Freeman <bf1936@att.com> | 2017-11-12 22:34:34 +0000 |
|---|---|---|
| committer | Brian Freeman <bf1936@att.com> | 2017-11-12 22:42:47 +0000 |
| commit | 024e6d1689ee38b37ac054636557b5dff8f26270 (patch) | |
| tree | dd10eefd3c71323b0ddd1237aa429a0c1faa5f5d /dmaap-listener/src | |
| parent | 292cce64a1a610283306a5f2280c787d8edb916d (diff) | |
Change dmaapClient dependency
Issue-ID: CCSDK-142
Change-Id: I5a3cd0626c71eadd414ab9939774d159638b99a6
Signed-off-by: Brian Freeman <bf1936@att.com>
Diffstat (limited to 'dmaap-listener/src')
| -rw-r--r-- | dmaap-listener/src/main/java/org/onap/ccsdk/sli/northbound/dmaapclient/SdncDmaapConsumer.java | 10 |
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; |