From 024e6d1689ee38b37ac054636557b5dff8f26270 Mon Sep 17 00:00:00 2001 From: Brian Freeman Date: Sun, 12 Nov 2017 22:34:34 +0000 Subject: Change dmaapClient dependency Issue-ID: CCSDK-142 Change-Id: I5a3cd0626c71eadd414ab9939774d159638b99a6 Signed-off-by: Brian Freeman --- dmaap-listener/pom.xml | 20 ++++++++++++++++---- .../northbound/dmaapclient/SdncDmaapConsumer.java | 10 ++++++++-- 2 files changed, 24 insertions(+), 6 deletions(-) (limited to 'dmaap-listener') diff --git a/dmaap-listener/pom.xml b/dmaap-listener/pom.xml index d1e173ca..0ebde6ce 100755 --- a/dmaap-listener/pom.xml +++ b/dmaap-listener/pom.xml @@ -18,7 +18,8 @@ 2.9.0.pr1 true /opt/app/dmaap-listener - 0.2.12 + 1.0.0-SNAPSHOT + yyMMdd-HHmmss ${maven.build.timestamp} ${project.version}-${build.number} @@ -27,7 +28,7 @@ - com.att.nsa + org.onap.dmaap.messagerouter.dmaapclient dmaapClient ${dmaap.listener.version} @@ -97,8 +98,19 @@ 1.7 - - + + org.apache.maven.plugins + maven-jar-plugin + 2.6 + + + + true + org.onap.ccsdk.sli.northbound.dmaapclient.DmaapListener + + + + maven-assembly-plugin 2.6 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; -- cgit 1.2.3-korg