summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorshentao <shentao@chinamobile.com>2017-11-16 04:11:56 +0800
committershentao <shentao@chinamobile.com>2017-11-16 04:12:03 +0800
commit8415db122ed6148ebb7c462ae268bd72a1451ed9 (patch)
treef79a1c20e0427a30cef21bff33a4d921cee5473a
parent919401afdaa375b8f3006186224c987841427123 (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.java7
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......");