diff options
author | shentao <shentao@chinamobile.com> | 2017-11-16 04:11:56 +0800 |
---|---|---|
committer | shentao <shentao@chinamobile.com> | 2017-11-16 04:12:03 +0800 |
commit | 8415db122ed6148ebb7c462ae268bd72a1451ed9 (patch) | |
tree | f79a1c20e0427a30cef21bff33a4d921cee5473a | |
parent | 919401afdaa375b8f3006186224c987841427123 (diff) |
Change dmaap ip configurations
Change-Id: Ie6c10e2c88fdd1b783dca4f0e03bd0c8d27dd6a4
Issue-Id: USECASEUI-54
Signed-off-by: shentao <shentao@chinamobile.com>
-rw-r--r-- | server/src/main/java/org/onap/usecaseui/server/util/DmaapSubscriber.java | 7 |
1 files changed, 2 insertions, 5 deletions
diff --git a/server/src/main/java/org/onap/usecaseui/server/util/DmaapSubscriber.java b/server/src/main/java/org/onap/usecaseui/server/util/DmaapSubscriber.java index d0664c81..9a6b14fd 100644 --- a/server/src/main/java/org/onap/usecaseui/server/util/DmaapSubscriber.java +++ b/server/src/main/java/org/onap/usecaseui/server/util/DmaapSubscriber.java @@ -118,12 +118,10 @@ public class DmaapSubscriber implements Runnable { Properties p = new Properties(); try { p.load(inputStream); - //this.url = p.getProperty("dmaap.url") + System.getenv("MR_ADDR"); - this.url = "http://172.30.3.42:3904"; + this.url = p.getProperty("dmaap.url") + System.getenv("MR_ADDR"); this.alarmTopic = p.getProperty("dmaap.alarmTopic"); this.performanceTopic = p.getProperty("dmaap.performanceTopic"); - //this.consumerGroup = p.getProperty("dmaap.consumerGroup"); - this.consumerGroup = "gaolei"; + this.consumerGroup = p.getProperty("dmaap.consumerGroup"); this.consumer = p.getProperty("dmaap.consumer"); this.timeout = Integer.parseInt(p.getProperty("dmaap.timeout")); } catch (IOException e1) { @@ -133,7 +131,6 @@ public class DmaapSubscriber implements Runnable { public void run() { try { - //logger.info((alarmsHeaderService == null)+""); initConfig(); while (isActive) { logger.info("alarm data subscription is starting......"); |