2 * Copyright 2017 BOCO Corporation. CMCC Technologies Co., Ltd
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
8 * http://www.apache.org/licenses/LICENSE-2.0
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.
16 package org.onap.vfc.nfvo.emsdriver.northbound.client;
18 import java.text.ParseException;
19 import java.text.SimpleDateFormat;
20 import java.util.Date;
22 import java.util.Properties;
24 import org.slf4j.Logger;
25 import org.slf4j.LoggerFactory;
26 import org.apache.log4j.Level;
27 import org.onap.vfc.nfvo.emsdriver.commons.constant.Constant;
28 import org.onap.vfc.nfvo.emsdriver.commons.utils.DriverThread;
29 import org.onap.vfc.nfvo.emsdriver.configmgr.ConfigurationInterface;
30 import org.onap.vfc.nfvo.emsdriver.messagemgr.MessageChannel;
31 import org.onap.vfc.nfvo.emsdriver.messagemgr.MessageChannelFactory;
33 import com.alibaba.fastjson.JSONObject;
35 import evel_javalibrary.att.com.AgentMain;
36 import evel_javalibrary.att.com.AgentMain.EVEL_ERR_CODES;
37 import evel_javalibrary.att.com.EvelFault;
38 import evel_javalibrary.att.com.EvelFault.EVEL_SEVERITIES;
39 import evel_javalibrary.att.com.EvelFault.EVEL_SOURCE_TYPES;
40 import evel_javalibrary.att.com.EvelFault.EVEL_VF_STATUSES;
41 import evel_javalibrary.att.com.EvelHeader;
42 import evel_javalibrary.att.com.EvelScalingMeasurement;
44 public class NorthMessageMgr extends DriverThread {
45 protected static final Logger logger = LoggerFactory.getLogger(NorthMessageMgr.class);
46 private MessageChannel alarmChannel = MessageChannelFactory.getMessageChannel(Constant.RESULT_CHANNEL_KEY);
47 private MessageChannel collectResultPMChannel = MessageChannelFactory.getMessageChannel(Constant.COLLECT_RESULT_PM_CHANNEL_KEY);
48 private MessageChannel collectResultChannel = MessageChannelFactory.getMessageChannel(Constant.COLLECT_RESULT_CHANNEL_KEY);
49 private ConfigurationInterface configurationInterface;
51 private boolean threadStop = false;
52 private Level level = Level.DEBUG;
55 public void dispose() {
56 logger.info("NorthMessageMgr Thread start threadStop=" + threadStop);
58 Properties properties = configurationInterface.getProperties();
59 String eventApiUrl = properties.getProperty("event_api_url");
60 String port = properties.getProperty("port");
61 String path = properties.getProperty("path");
62 String topic = properties.getProperty("topic");
63 String username = properties.getProperty("username");
64 String password = properties.getProperty("password");
65 String keystore_path ="" ;
66 String jks_password = "";
67 String key_password = "";
68 String levelStr = properties.getProperty("level");
69 if ("debug".equals(levelStr)) {
76 eventApiUrl = "http://" + eventApiUrl;
77 logger.info("AgentMain.evel_initialize start event_api_url=[" + eventApiUrl + "]port=[" + port + "]path=[" + path + "]"
78 + "topic=[" + topic + "]username=[" + username + /*"]password=[" + password +*/ "]level=[" + level + "]");
80 EVEL_ERR_CODES evecode = AgentMain.evel_initialize(eventApiUrl, Integer.parseInt(port),
88 logger.info("AgentMain.evel_initialize sucess EVEL_ERR_CODES=" + evecode);
89 } catch (Exception e) {
90 logger.error("AgentMain.evel_initialize fail ", e);
92 } catch (Exception e2) {
93 logger.error("NorthMessageMgr start fail ", e2);
96 new HeatBeatTread().start();
98 new AlarmMessageRecv().start();
100 new ResultMessageRecv().start();
102 new CollectMessageRecv().start();
104 logger.info("NorthMessageMgr start sucess ");
108 * @return the configurationInterface
110 public ConfigurationInterface getConfigurationInterface() {
111 return configurationInterface;
115 * @param configurationInterface the configurationInterface to set
117 public void setConfigurationInterface(
118 ConfigurationInterface configurationInterface) {
119 this.configurationInterface = configurationInterface;
122 class HeatBeatTread extends Thread {
126 while (!threadStop) {
129 EvelHeader header = EvelHeader.evel_new_heartbeat("Hearbeat_EMS", "EMS-driver");
130 header.evel_nfnamingcode_set("EMS-driver");
131 header.evel_nfcnamingcode_set("EMS-driver");
132 AgentMain.evel_post_event(header);
133 logger.info("HeatBeat send!");
135 Thread.sleep(60 * 1000L);//60 secs
136 } catch (Exception e) {
137 logger.error("Unable to sleep the HB thread ", e);
139 } catch (Exception e) {
140 logger.error("HeatBeatTread exception", e);
146 class AlarmMessageRecv extends Thread {
147 long timeStamp = System.currentTimeMillis();
151 while (!threadStop) {
154 if (System.currentTimeMillis() - timeStamp > Constant.ONEMINUTE) {
155 timeStamp = System.currentTimeMillis();
157 logger.info("ALARM_CHANNEL Msg size :" + alarmChannel.size());
160 Object obj = alarmChannel.poll();
164 if (obj instanceof String) {
165 String result = (String) obj;
166 JSONObject reagobj = JSONObject.parseObject(result);
168 EvelFault evelFault = this.resultEvelFault(reagobj);
171 logger.info("AgentMain.evel_post_event alarm start");
172 AgentMain.evel_post_event(evelFault);
173 logger.info("AgentMain.evel_post_event alarm sucess");
175 logger.error("AlarmMessageRecv receive Object = " + obj);
178 } catch (Exception e) {
179 logger.error("AlarmMessageRecv exception", e);
184 private EvelFault resultEvelFault(JSONObject reagobj) {
186 String eventName = null;
187 EvelHeader.PRIORITIES pri = null;
188 EVEL_SEVERITIES severity = null;
189 EVEL_VF_STATUSES status = null;
190 String alarmStatus = reagobj.getString("alarmStatus");
191 String origSeverity = reagobj.getString("origSeverity");
192 if ("0".equals(alarmStatus)) {
193 status = EVEL_VF_STATUSES.EVEL_VF_STATUS_IDLE;
194 eventName = "Fault_" + reagobj.getString("neType") + "_" + reagobj.getString("alarmTitle") + "Cleared";
196 if ("1".equals(origSeverity)) {
197 severity = EVEL_SEVERITIES.EVEL_SEVERITY_CRITICAL;
198 pri = EvelHeader.PRIORITIES.EVEL_PRIORITY_HIGH;
199 } else if ("2".equals(origSeverity)) {
200 severity = EVEL_SEVERITIES.EVEL_SEVERITY_MAJOR;
201 pri = EvelHeader.PRIORITIES.EVEL_PRIORITY_MEDIUM;
202 } else if ("3".equals(origSeverity)) {
203 severity = EVEL_SEVERITIES.EVEL_SEVERITY_MINOR;
204 pri = EvelHeader.PRIORITIES.EVEL_PRIORITY_NORMAL;
205 } else if ("4".equals(origSeverity)) {
206 severity = EVEL_SEVERITIES.EVEL_SEVERITY_WARNING;
207 pri = EvelHeader.PRIORITIES.EVEL_PRIORITY_LOW;
211 status = EVEL_VF_STATUSES.EVEL_VF_STATUS_ACTIVE;
212 eventName = "Fault_" + reagobj.getString("neType") + "_" + reagobj.getString("alarmTitle");
213 pri = EvelHeader.PRIORITIES.EVEL_PRIORITY_NORMAL;
214 severity = EVEL_SEVERITIES.EVEL_SEVERITY_NORMAL;
217 String evnId = reagobj.getString("alarmId");
218 String alarmCondition = reagobj.getString("specificProblem");
220 String specificProblem = reagobj.getString("specificProblem");
222 EvelFault flt = new EvelFault(eventName, evnId, alarmCondition,
223 specificProblem, pri, severity,
224 EVEL_SOURCE_TYPES.EVEL_SOURCE_VIRTUAL_NETWORK_FUNCTION,
226 flt.evel_nfcnamingcode_set("");
227 flt.evel_nfnamingcode_set("");
228 flt.evel_header_type_set("applicationVnf");
229 String eventTime = reagobj.getString("eventTime");
230 SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
231 Date eventTimeD = new Date();
233 eventTimeD = format.parse(eventTime);
234 } catch (ParseException e) {
235 logger.error("ParseException ", e);
237 flt.evel_start_epoch_set(eventTimeD.getTime());
238 flt.evel_last_epoch_set(eventTimeD.getTime());
240 flt.evel_fault_category_set(reagobj.getString("alarmType"));
241 flt.evel_fault_interface_set(reagobj.getString("objectName"));
242 String neUID = reagobj.getString("neUID");
243 flt.evel_reporting_entity_id_set(neUID.substring(0, 9));//
244 flt.evel_reporting_entity_name_set(neUID.substring(0, 9));
245 flt.evel_header_set_sourceid(true, reagobj.getString("neName"));
246 flt.evel_header_set_source_name(reagobj.getString("objectName"));
248 flt.evel_header_set_priority(pri);
249 for (String key : reagobj.keySet()) {
250 flt.evel_fault_addl_info_add(key, reagobj.getString(key));
257 class ResultMessageRecv extends Thread {
258 long timeStamp = System.currentTimeMillis();
262 while (!threadStop) {
265 if (System.currentTimeMillis() - timeStamp > Constant.ONEMINUTE) {
266 timeStamp = System.currentTimeMillis();
268 logger.debug("COLLECT_RESULT_CHANNEL Msg size :" + collectResultChannel.size());
271 Object obj = collectResultChannel.poll();
275 if (obj instanceof String) {
277 Properties properties = configurationInterface.getProperties();
278 String msbAddress = properties.getProperty("msbAddress");
279 String url = properties.getProperty("dataNotifyUrl");
280 String postUrl = "http://" + msbAddress + url;
281 HttpClientUtil.doPost(postUrl, (String) obj, Constant.ENCODING_UTF8);
284 } catch (Exception e) {
285 logger.error("ResultMessageRecv exception", e);
291 class CollectMessageRecv extends Thread {
292 long timeStamp = System.currentTimeMillis();
296 logger.info("CollectMessageRecv Thread is start threadStop=" + threadStop);
297 while (!threadStop) {
300 if (System.currentTimeMillis() - timeStamp > Constant.ONEMINUTE) {
301 timeStamp = System.currentTimeMillis();
303 logger.debug(Constant.COLLECT_RESULT_PM_CHANNEL_KEY + " Msg size :" + collectResultPMChannel.size());
306 Object obj = collectResultPMChannel.poll();
310 if (obj instanceof Map) {
311 @SuppressWarnings("unchecked")
312 Map<String, String> reMap = (Map<String, String>) obj;
313 logger.debug("reMap =" + reMap);
314 EvelScalingMeasurement evelScalingMeasurement = this.resultEvelScalingMeasurement(reMap);
315 logger.debug("evelScalingMeasurement=" + evelScalingMeasurement);
317 logger.info("AgentMain.evel_post_event start");
318 AgentMain.evel_post_event(evelScalingMeasurement);
319 logger.info("AgentMain.evel_post_event sucess");
322 logger.error("CollectMessageRecv receive Object = " + obj);
325 } catch (Exception e) {
326 logger.error("CollectMessageRecv exception", e);
331 private EvelScalingMeasurement resultEvelScalingMeasurement(Map<String, String> reMap) {
332 String evname = "Mfvs_" + reMap.get("ElementType") + reMap.get("ObjectType");
333 String evid = reMap.get("StartTime") + reMap.get("ObjectType") + reMap.get("rmUID");
334 int period = Integer.parseInt(reMap.get("Period") != null ? reMap.get("Period") : "15");
335 EvelScalingMeasurement sm = new EvelScalingMeasurement(period, evname, evid);
337 for (String key : reMap.keySet()) {
338 sm.evel_measurement_custom_measurement_add(reMap.get("ElementType"), key, reMap.get(key));
342 sm.evel_nfcnamingcode_set("");
343 sm.evel_nfnamingcode_set("");
344 sm.evel_header_type_set("applicationVnf");
345 String rmUID = reMap.get("rmUID");
346 sm.evel_reporting_entity_id_set(rmUID.substring(0, 9));//
347 String dn = reMap.get("Dn");
349 sm.evel_reporting_entity_name_set(dn.substring(0, dn.indexOf(";") > -1 ? dn.indexOf(";") : dn.length()));//0 is valid index
351 // decide the flow if Dn is null
354 sm.evel_header_set_sourceid(true, reMap.get("rmUID"));
355 sm.evel_header_set_source_name(reMap.get("rmUID"));
357 sm.evel_header_set_priority(EvelHeader.PRIORITIES.EVEL_PRIORITY_NORMAL);