modify not publish messages to DMaaP
[holmes/common.git] / holmes-actions / src / main / java / org / onap / holmes / common / dcae / DcaeConfigurationQuery.java
1 /*
2  * Copyright 2017 ZTE Corporation.
3  *
4  * Licensed under the Apache License, Version 2.0 (the "License");
5  * you may not use this file except in compliance with the License.
6  * You may obtain a copy of the License at
7  *
8  * http://www.apache.org/licenses/LICENSE-2.0
9  *
10  * Unless required by applicable law or agreed to in writing, software
11  * distributed under the License is distributed on an "AS IS" BASIS,
12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13  * See the License for the specific language governing permissions and
14  * limitations under the License.
15  */
16 package org.onap.holmes.common.dcae;
17
18 import javax.ws.rs.client.Client;
19 import javax.ws.rs.client.ClientBuilder;
20 import javax.ws.rs.client.WebTarget;
21 import org.glassfish.jersey.client.ClientConfig;
22 import org.jvnet.hk2.annotations.Service;
23 import org.onap.holmes.common.config.MicroServiceConfig;
24 import org.onap.holmes.common.dcae.entity.DcaeConfigurations;
25 import org.onap.holmes.common.dcae.utils.DcaeConfigurationParser;
26 import org.onap.holmes.common.exception.CorrelationException;
27
28 public class DcaeConfigurationQuery {
29
30     public static DcaeConfigurations getDcaeConfigurations(String hostname)
31             throws CorrelationException {
32         String serviceAddrInfo = MicroServiceConfig.getServiceAddrInfoFromCBS(hostname);
33         String response = getDcaeResponse(serviceAddrInfo);
34         DcaeConfigurations dcaeConfigurations = null;
35         dcaeConfigurations = DcaeConfigurationParser.parse(response);
36         return dcaeConfigurations;
37     }
38
39     private static String getDcaeResponse(String serviceAddrInfo) {
40         Client client = ClientBuilder.newClient(new ClientConfig());
41         WebTarget webTarget = client.target(serviceAddrInfo);
42         return webTarget.request("application/json").get()
43                 .readEntity(String.class);
44     }
45 }