summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat
-rw-r--r--dmaap-dsa/src/main/java/org/onap/holmes/dsa/dmaappolling/DMaaPResponseUtil.java110
-rw-r--r--dmaap-dsa/src/main/java/org/onap/holmes/dsa/dmaappolling/Subscriber.java88
2 files changed, 198 insertions, 0 deletions
diff --git a/dmaap-dsa/src/main/java/org/onap/holmes/dsa/dmaappolling/DMaaPResponseUtil.java b/dmaap-dsa/src/main/java/org/onap/holmes/dsa/dmaappolling/DMaaPResponseUtil.java
new file mode 100644
index 0000000..72b76c1
--- /dev/null
+++ b/dmaap-dsa/src/main/java/org/onap/holmes/dsa/dmaappolling/DMaaPResponseUtil.java
@@ -0,0 +1,110 @@
+/*
+ * 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 com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.List;
+import org.jvnet.hk2.annotations.Service;
+import org.onap.holmes.common.api.stat.AlarmAdditionalField;
+import org.onap.holmes.common.api.stat.VesAlarm;
+
+@Service
+public class DMaaPResponseUtil {
+
+ public VesAlarm convertJsonToVesAlarm(String responseJson) throws IOException {
+ ObjectMapper mapper = new ObjectMapper();
+ JsonNode jsonNode = mapper.readTree(responseJson);
+ VesAlarm vesAlarm = new VesAlarm();
+
+ JsonNode eventJson = jsonNode.get("event");
+
+ JsonNode commonEventHeaderJson = eventJson.get("commonEventHeader");
+ convertCommonEventHeaderJsonToEvent(commonEventHeaderJson, vesAlarm);
+
+ JsonNode faultFieldsJson = eventJson.get("faultFields");
+ convertFaultFieldsJsonToEvent(faultFieldsJson, vesAlarm);
+ return vesAlarm;
+ }
+
+ private void convertCommonEventHeaderJsonToEvent(JsonNode commonEventHeaderJson,
+ VesAlarm vesAlarm) {
+ vesAlarm.setDomain(commonEventHeaderJson.get("domain").asText());
+ vesAlarm.setEventId(commonEventHeaderJson.get("eventId").asText());
+ vesAlarm.setEventName(commonEventHeaderJson.get("eventName").asText());
+ vesAlarm.setEventType(getTextElementByNode(commonEventHeaderJson, "eventType"));
+ vesAlarm.setInternalHeaderFields(
+ getTextElementByNode(commonEventHeaderJson, "internalHeaderFields"));
+ vesAlarm.setLastEpochMicrosec(commonEventHeaderJson.get("lastEpochMicfrosec").asLong());
+ vesAlarm.setNfcNamingCode(getTextElementByNode(commonEventHeaderJson, "nfcNamingCode"));
+ vesAlarm.setNfNamingCode(getTextElementByNode(commonEventHeaderJson, "nfNamingCode"));
+ vesAlarm.setPriority(commonEventHeaderJson.get("priority").asText());
+ vesAlarm.setReportingEntityId(
+ getTextElementByNode(commonEventHeaderJson, "reportingEntityId"));
+ vesAlarm.setReportingEntityName(commonEventHeaderJson.get("reprotingEntityName").asText());
+ vesAlarm.setSequence(commonEventHeaderJson.get("sequence").asInt());
+ vesAlarm.setSourceId(getTextElementByNode(commonEventHeaderJson, "sourceId"));
+ vesAlarm.setSourceName(commonEventHeaderJson.get("sourceName").asText());
+ vesAlarm.setStartEpochMicrosec(commonEventHeaderJson.get("startEpochMicrosec").asLong());
+ vesAlarm.setVersion(commonEventHeaderJson.get("version").asLong());
+ }
+
+ private void convertFaultFieldsJsonToEvent(JsonNode faultFieldsJson, VesAlarm vesAlarm) {
+ vesAlarm.setAlarmAdditionalInformation(getListElementByNode(faultFieldsJson, "alarmAdditionalInformation"));
+ vesAlarm.setAlarmCondition(faultFieldsJson.get("alarmCondition").asText());
+ vesAlarm.setAlarmInterfaceA(getTextElementByNode(faultFieldsJson, "alarmInterfaceA"));
+ vesAlarm.setEventCategory(getTextElementByNode(faultFieldsJson,"eventCategory"));
+ vesAlarm.setEventSeverity(faultFieldsJson.get("eventSeverity").asText());
+ vesAlarm.setEventSourceType(faultFieldsJson.get("eventSourceType").asText());
+ vesAlarm.setFaultFieldsVersion(faultFieldsJson.get("faultFieldsVersion").asLong());
+ vesAlarm.setSpecificProblem(faultFieldsJson.get("specificProblem").asText());
+ vesAlarm.setVfStatus(faultFieldsJson.get("vfStatus").asText());
+ }
+
+ private String getTextElementByNode(JsonNode jsonNode,String name){
+ if(jsonNode.has(name)){
+ return jsonNode.get(name).asText();
+ }
+ return null;
+ }
+
+ private Long getLongElementByNode(JsonNode jsonNode, String name) {
+ if(jsonNode.has(name)){
+ return jsonNode.get(name).asLong();
+ }
+ return null;
+ }
+
+ private List<AlarmAdditionalField> getListElementByNode(JsonNode jsonNode, String name){
+ List<AlarmAdditionalField> alarms = new ArrayList<AlarmAdditionalField>();
+ if (jsonNode.has(name)) {
+ JsonNode alarmAdditionalInformations = jsonNode.get(name);
+ if (alarmAdditionalInformations.isArray()) {
+ alarmAdditionalInformations.forEach(alarm -> {
+ if(alarm.has("name") && alarm.has("value")) {
+ AlarmAdditionalField field = new AlarmAdditionalField();
+ field.setName(getTextElementByNode(alarm, "name"));
+ field.setName(getTextElementByNode(alarm, "value"));
+ alarms.add(field);
+ }
+ });
+ }
+ }
+ return alarms;
+ }
+}
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;
+ }
+}