diff options
Diffstat (limited to 'holmes-actions/src/main/java/org/onap/holmes/common/config/MicroServiceConfig.java')
| -rw-r--r-- | holmes-actions/src/main/java/org/onap/holmes/common/config/MicroServiceConfig.java | 23 |
1 files changed, 13 insertions, 10 deletions
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 7cbbb3e..7566fa1 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 @@ -1,5 +1,5 @@ /**
- * Copyright 2017-2020 ZTE Corporation.
+ * Copyright 2017-2021 ZTE Corporation.
* <p>
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -15,6 +15,7 @@ */
package org.onap.holmes.common.config;
+import com.google.gson.JsonArray;
import com.google.gson.JsonObject;
import com.google.gson.JsonParser;
import org.onap.holmes.common.constant.AlarmConst;
@@ -59,14 +60,16 @@ public class MicroServiceConfig { String queryString = getConsulAddrInfo() + hostname;
log.info("Query the " + hostname + " address using the URL: " + queryString);
try {
- JsonObject addrJson = JsonParser.parseString(execQuery(queryString))
- .getAsJsonArray()
- .get(0)
- .getAsJsonObject();
- if (addrJson != null && addrJson.get("ServiceAddress") != null
- && addrJson.get("ServicePort") != null) {
- ret = "http://" + addrJson.get("ServiceAddress").getAsString() + ":" + addrJson
- .get("ServicePort").getAsString();
+ JsonArray addrArray = JsonParser.parseString(execQuery(queryString)).getAsJsonArray();
+ if (addrArray.size() > 0) {
+ JsonObject addrJson = addrArray.get(0).getAsJsonObject();
+ if (addrJson != null && addrJson.get("ServiceAddress") != null
+ && addrJson.get("ServicePort") != null) {
+ ret = "http://" + addrJson.get("ServiceAddress").getAsString() + ":" + addrJson
+ .get("ServicePort").getAsString();
+ }
+ } else {
+ log.info("No service info is returned from DCAE Consul. Hostname: {}", hostname);
}
} catch (Exception e) {
log.warn(e.getMessage(), e);
@@ -107,7 +110,7 @@ public class MicroServiceConfig { }
public static String[] getMsbIpAndPort() {
- return new String[] {getEnv(MSB_IAG_SERVICE_HOST), getEnv(MSB_IAG_SERVICE_PORT)};
+ return new String[]{getEnv(MSB_IAG_SERVICE_HOST), getEnv(MSB_IAG_SERVICE_PORT)};
}
public static String[] getMicroServiceIpAndPort() {
|