Change dmaap ip configurations 77/23677/1
authorshentao <shentao@chinamobile.com>
Wed, 15 Nov 2017 20:11:56 +0000 (04:11 +0800)
committershentao <shentao@chinamobile.com>
Wed, 15 Nov 2017 20:12:03 +0000 (04:12 +0800)
Change-Id: Ie6c10e2c88fdd1b783dca4f0e03bd0c8d27dd6a4
Issue-Id: USECASEUI-54
Signed-off-by: shentao <shentao@chinamobile.com>
server/src/main/java/org/onap/usecaseui/server/util/DmaapSubscriber.java

index d0664c8..9a6b14f 100644 (file)
@@ -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......");