- private List<String> getDMaaPData() {
- Client client = ClientBuilder.newClient(new ClientConfig());
- WebTarget webTarget = client.target(url);
- Response response = webTarget.path(topic).path(consumerGroup).path(consumer).request().get();
- return response.readEntity(List.class);
+ private List<String> getDMaaPData() throws Exception {
+ String response;
+ try {
+ HttpResponse httpResponse = HttpsUtils
+ .get(url + "/" + consumerGroup + "/" + consumer, new HashMap<>(), timeout);
+ response = HttpsUtils.extractResponseEntity(httpResponse);
+ } catch (Exception e) {
+ throw e;
+ }
+ return GsonUtil.jsonToBean(response, List.class);