*/
package org.onap.holmes.common.dcae;
-import javax.ws.rs.client.Client;
-import javax.ws.rs.client.ClientBuilder;
-import javax.ws.rs.client.WebTarget;
-import org.glassfish.jersey.client.ClientConfig;
import org.onap.holmes.common.config.MicroServiceConfig;
import org.onap.holmes.common.dcae.entity.DcaeConfigurations;
import org.onap.holmes.common.dcae.utils.DcaeConfigurationParser;
public static DcaeConfigurations getDcaeConfigurations(String hostname)
throws CorrelationException {
- String serviceAddrInfo = MicroServiceConfig.getServiceConfigInfoFromCBS(hostname);
- String response;
- try {
- response = getDcaeResponse(serviceAddrInfo);
- } catch (Exception e) {
- throw new CorrelationException("Failed to connect to DCAE. ", e);
- }
- DcaeConfigurations dcaeConfigurations = null;
- dcaeConfigurations = DcaeConfigurationParser.parse(response);
- return dcaeConfigurations;
- }
-
- private static String getDcaeResponse(String serviceAddrInfo) {
- Client client = ClientBuilder.newClient(new ClientConfig());
- WebTarget webTarget = client.target(serviceAddrInfo);
- return webTarget.request("application/json").get()
- .readEntity(String.class);
+ String serviceConfig = MicroServiceConfig.getServiceConfigInfoFromCBS(hostname);
+ return DcaeConfigurationParser.parse(serviceConfig);
}
}