From: tang peng <tang.peng5@zte.com.cn>
Date: Tue, 31 Oct 2017 04:37:36 +0000 (+0000)
Subject: Merge "Update the logic for MSB addr Query"
X-Git-Tag: v1.0.0~9
X-Git-Url: https://gerrit.onap.org/r/gitweb?a=commitdiff_plain;h=d30677e80b8756048f9633ecba4c26360e3f644c;hp=8813646a1076600646630eba58940b7b7ba46c90;p=holmes%2Fcommon.git

Merge "Update the logic for MSB addr Query"
---

diff --git a/holmes-actions/src/main/java/org/onap/holmes/common/config/MicroServiceConfig.java b/holmes-actions/src/main/java/org/onap/holmes/common/config/MicroServiceConfig.java
index 212bc66..d86f56c 100644
--- a/holmes-actions/src/main/java/org/onap/holmes/common/config/MicroServiceConfig.java
+++ b/holmes-actions/src/main/java/org/onap/holmes/common/config/MicroServiceConfig.java
@@ -98,10 +98,15 @@ public class MicroServiceConfig {
         //String info = getServiceAddrInfoFromCBS(MSB_ADDR);
         String info = getServiceAddrInfoFromCBS(getEnv(HOSTNAME));
         log.info("Got the service information of \"" + getEnv(HOSTNAME) + "\" from CBS. The response is " + info + ".");
-        JSONObject infoObj = JSONObject.fromObject(info);
-        info = infoObj.has("msb.hostname") ? infoObj.getString("msb.hostname") : null;
+
         if (info != null){
-            msbServerInfo = split(info);
+            JSONObject infoObj = JSONObject.fromObject(info);
+            String msbInfoTmp = infoObj.has("msb.hostname") ? infoObj.getString("msb.hostname") : null;
+            if (msbInfoTmp != null) {
+                msbServerInfo = split(msbInfoTmp);
+            } else {
+                msbServerInfo = split(getEnv(MSB_ADDR));
+            }
         } else {
             msbServerInfo = split(getEnv(MSB_ADDR));
         }
diff --git a/holmes-actions/src/main/java/org/onap/holmes/common/dcae/DcaeConfigurationQuery.java b/holmes-actions/src/main/java/org/onap/holmes/common/dcae/DcaeConfigurationQuery.java
index 8dd3690..897f689 100644
--- a/holmes-actions/src/main/java/org/onap/holmes/common/dcae/DcaeConfigurationQuery.java
+++ b/holmes-actions/src/main/java/org/onap/holmes/common/dcae/DcaeConfigurationQuery.java
@@ -34,7 +34,7 @@ public class DcaeConfigurationQuery {
         try {
             response = getDcaeResponse(serviceAddrInfo);
         } catch (Exception e) {
-            throw new CorrelationException("Failed to connect to dcae", e);
+            throw new CorrelationException("Failed to connect to DCAE. ", e);
         }
         DcaeConfigurations dcaeConfigurations = null;
         dcaeConfigurations = DcaeConfigurationParser.parse(response);