diff options
Diffstat (limited to 'dmaap-dsa/src/main/java/org/onap/holmes/dsa/dmaappolling/Subscriber.java')
-rw-r--r-- | dmaap-dsa/src/main/java/org/onap/holmes/dsa/dmaappolling/Subscriber.java | 88 |
1 files changed, 88 insertions, 0 deletions
diff --git a/dmaap-dsa/src/main/java/org/onap/holmes/dsa/dmaappolling/Subscriber.java b/dmaap-dsa/src/main/java/org/onap/holmes/dsa/dmaappolling/Subscriber.java new file mode 100644 index 0000000..3563b66 --- /dev/null +++ b/dmaap-dsa/src/main/java/org/onap/holmes/dsa/dmaappolling/Subscriber.java @@ -0,0 +1,88 @@ +/* + * Copyright 2017 ZTE Corporation. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.onap.holmes.dsa.dmaappolling; + +import java.io.IOException; +import java.util.ArrayList; +import java.util.List; +import javax.inject.Inject; +import javax.ws.rs.client.Client; +import javax.ws.rs.client.ClientBuilder; +import javax.ws.rs.client.WebTarget; +import javax.ws.rs.core.Response; +import lombok.Getter; +import lombok.Setter; +import org.glassfish.jersey.client.ClientConfig; +import org.onap.holmes.common.api.stat.VesAlarm; +import org.onap.holmes.common.exception.CorrelationException; + +@Getter +@Setter +public class Subscriber { + + @Inject + private DMaaPResponseUtil dMaaPResponseUtil; + + /** + * The number of milliseconds to wait for messages if none are immediately available. This + * should normally be used, and set at 15000 or higher. + */ + private int timeout = 15000; + + /** + * The maximum number of messages to return + */ + private int limit = 100; + + /** + * The number of milliseconds to poll interval time. This should normally be used, and set at + * 15000 or higher. + */ + private int period = 15000; + + private boolean secure; + private String topic; + private String url; + private String consumerGroup = "g0"; + private String consumer = "u1"; + private String authInfo; + private String authExpDate; + + public List<VesAlarm> subscribe() throws CorrelationException { + List<String> response = getDMaaPData(); + try { + return extractVesAlarm(response); + } catch (Exception e) { + throw new CorrelationException("Failed to convert the response data to VES alarms.", e); + } + } + + 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); + } + + List<VesAlarm> extractVesAlarm(List<String> responseEntity) throws IOException { + List<VesAlarm> vesAlarmList = new ArrayList<>(); + for (String entity : responseEntity) { + vesAlarmList.add(dMaaPResponseUtil.convertJsonToVesAlarm(entity)); + } + return vesAlarmList; + } +} |