X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=rulemgt%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fholmes%2Frulemgt%2Fmsb%2FEngineIpList.java;h=2e9199347154d4d4b16d10b68dc008ac0b6b0a6f;hb=8635bde272f6f2da05dd4dc274e0d91a640c0088;hp=cfccd18fe3b262e7c6eafc1902cf5e44eea0833b;hpb=580d4ce637b1c09b3bd2258b0b9c8332b8789bad;p=holmes%2Frule-management.git diff --git a/rulemgt/src/main/java/org/onap/holmes/rulemgt/msb/EngineIpList.java b/rulemgt/src/main/java/org/onap/holmes/rulemgt/msb/EngineIpList.java index cfccd18..2e91993 100644 --- a/rulemgt/src/main/java/org/onap/holmes/rulemgt/msb/EngineIpList.java +++ b/rulemgt/src/main/java/org/onap/holmes/rulemgt/msb/EngineIpList.java @@ -16,7 +16,11 @@ package org.onap.holmes.rulemgt.msb; +import java.io.IOException; +import lombok.extern.slf4j.Slf4j; import org.apache.http.HttpResponse; +import org.apache.http.client.methods.HttpGet; +import org.apache.http.impl.client.CloseableHttpClient; import org.jvnet.hk2.annotations.Service; import org.onap.holmes.common.api.entity.ServiceEntity; import org.onap.holmes.common.api.entity.ServiceNode4Query; @@ -30,6 +34,7 @@ import java.util.HashMap; import java.util.List; @Service +@Slf4j public class EngineIpList { private String[] msbAddrInfo; @@ -46,21 +51,24 @@ public class EngineIpList { } public List getServiceCount()throws Exception{ - String response; - try { - HttpResponse httpResponse = HttpsUtils - .get(url, new HashMap<>()); - response = HttpsUtils.extractResponseEntity(httpResponse); - } catch (Exception e) { - throw e; - } - ServiceEntity service = GsonUtil.jsonToBean(response, ServiceEntity.class); - List nodesList = service.getNodes(); - List ipList = new ArrayList<>(); - for(ServiceNode4Query node : nodesList){ - ipList.add(node.getIp()); - } - return ipList; + String response; + HttpGet httpGet = new HttpGet(url); + try (CloseableHttpClient httpClient = HttpsUtils.getHttpClient(HttpsUtils.DEFUALT_TIMEOUT)) { + HttpResponse httpResponse = HttpsUtils.get(httpGet, new HashMap<>(), httpClient); + response = HttpsUtils.extractResponseEntity(httpResponse); + } catch (Exception e) { + throw e; + } finally { + httpGet.releaseConnection(); + + } + ServiceEntity service = GsonUtil.jsonToBean(response, ServiceEntity.class); + List nodesList = service.getNodes(); + List ipList = new ArrayList<>(); + for (ServiceNode4Query node : nodesList) { + ipList.add(node.getIp()); + } + return ipList; }