From: shentao <shentao@chinamobile.com>
Date: Wed, 15 Nov 2017 20:11:56 +0000 (+0800)
Subject: Change dmaap ip configurations
X-Git-Tag: v1.0.1~2
X-Git-Url: https://gerrit.onap.org/r/gitweb?a=commitdiff_plain;h=8415db122ed6148ebb7c462ae268bd72a1451ed9;p=usecase-ui%2Fserver.git

Change dmaap ip configurations

Change-Id: Ie6c10e2c88fdd1b783dca4f0e03bd0c8d27dd6a4
Issue-Id: USECASEUI-54
Signed-off-by: shentao <shentao@chinamobile.com>
---

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......");