diff options
Diffstat (limited to 'veslibrary/ves_javalibrary/evel_javalib2/src/main/java/evel_javalibrary/att/com/loadbalance/heartBeatData.java')
-rw-r--r-- | veslibrary/ves_javalibrary/evel_javalib2/src/main/java/evel_javalibrary/att/com/loadbalance/heartBeatData.java | 153 |
1 files changed, 0 insertions, 153 deletions
diff --git a/veslibrary/ves_javalibrary/evel_javalib2/src/main/java/evel_javalibrary/att/com/loadbalance/heartBeatData.java b/veslibrary/ves_javalibrary/evel_javalib2/src/main/java/evel_javalibrary/att/com/loadbalance/heartBeatData.java deleted file mode 100644 index 9da7521..0000000 --- a/veslibrary/ves_javalibrary/evel_javalib2/src/main/java/evel_javalibrary/att/com/loadbalance/heartBeatData.java +++ /dev/null @@ -1,153 +0,0 @@ -package evel_javalibrary.att.com.loadbalance; -/**************************************************************************//** - * @file - * Heartbeat field class - * - * This file implements the Heartbeat Event class which is intended to provide a - * simple wrapper around the complexity of AT&T's Vendor Event Listener API so - * that VNFs can use it to send Agent status. - * - * License - * ------- - * Unless otherwise specified, all software contained herein is - * 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. - *****************************************************************************/ - -import java.io.File; -import java.nio.charset.Charset; -import java.nio.file.Files; -import java.util.ArrayList; -import java.util.HashMap; -import java.util.List; - -import javax.json.Json; -import javax.json.JsonArray; -import javax.json.JsonArrayBuilder; -import javax.json.JsonObject; -import javax.json.JsonObjectBuilder; - -import evel_javalibrary.att.com.AgentMain; -import evel_javalibrary.att.com.EvelBatch; -import evel_javalibrary.att.com.EvelHeartbeatField; - -public class heartBeatData extends Thread{ - - static HashMap<String, String> hm = new HashMap<>(); - static HashMap<String, String> hb_config = new HashMap<>(); - static int gm_event_id = 1; - static String event_id1 = "mvfs"; - static String event_id2=null; - - - public void run() { - - Long start_epoch_microsec = 0L; - Long last_epoch_microsec = 0L; - - MeasureData mdataThread = new MeasureData(); - hm = mdataThread.read_common_config_file(); - read_hb_config_file(); - - while(true) { - event_id2 = event_id1+ (gm_event_id++); - - - EvelHeartbeatField evelHb = new EvelHeartbeatField(Integer.parseInt(hb_config.get("heartbeatInterval")) , - hb_config.get("eventName"), - event_id2); - - if( hm.get("eventType")!=null) { - - start_epoch_microsec = last_epoch_microsec; - last_epoch_microsec = System.nanoTime()/1000; - - evelHb.evel_last_epoch_set(start_epoch_microsec); - evelHb.evel_start_epoch_set(last_epoch_microsec); - - evelHb.evel_header_type_set(hm.get("eventType").toString()); - evelHb.evel_nfcnamingcode_set(hm.get("nfcNamingCode").toString()); - evelHb.evel_nfnamingcode_set(hm.get("nfNamingCode").toString()); - evelHb.evel_reporting_entity_name_set(hm.get("reportingEntityName").toString()); - evelHb.evel_reporting_entity_id_set(hm.get("reportingEntityId").toString()); - evelHb.evel_nfVendorName_set(hm.get("nfVendorName").toString()); - evelHb.evel_header_set_sourceid(true,hm.get("sourceId").toString()); - evelHb.evel_header_set_source_name(hm.get("sourceName").toString()); - - evelHb.evel_timeZoneOffset_set(hm.get("timeZoneOffset").toString()); - - - JsonObject obj = Json.createObjectBuilder() - .add( "heartbeatFields",evelHeartbeatFieldObject() - ).build(); - - EvelBatch ebt = new EvelBatch(); - //ebt.addEvent(evelHb); - - - System.out.println(" Event sent..."+ obj.asJsonObject()); - System.out.println("Event sent...###########"); - AgentMain.evel_post_event(evelHb); - System.out.println(" Event sent..."); - } - - try { - Thread.sleep(1000); - }catch(Exception e) { - - } - } - } - - - JsonObjectBuilder evelHeartbeatFieldObject() - { - String version = "3.0"; - JsonObjectBuilder evelHeatbeat = Json.createObjectBuilder() - .add("heartbeatInterval", hb_config.get("heartbeatInterval")); - evelHeatbeat.add( "heartbeatFieldsVersion", version); - return evelHeatbeat; - } - - - public static HashMap<String, String> read_hb_config_file() { - - List<String> list = new ArrayList<String>(); - - hb_config.put("eventName", ""); - hb_config.put("heartbeatInterval", ""); - - - System.out.println("KEYS: " + hb_config.keySet().size()); - System.out.println("VALUES: " + hb_config.values()); - - try { - //File file = new File("/home/ves/users/admin/temp/fw_hb_config.txt"); - File file = new File("./src/main/java/evel_javalibrary/att/com/loadbalance/fw_hb_config.txt"); - list = Files.readAllLines(file.toPath(), Charset.defaultCharset()); - for (String lineSplit : list) { - String[] res = lineSplit.split(" "); - hb_config.put(res[0], res[1]); -// System.out.println("File reading after split ---" + res[0]); -// System.out.println("File reading after split second---" + res[1]); - } - } catch (Exception ex) { - ex.printStackTrace(); - } - System.out.println("KEYS:hb_config " + hb_config.keySet().size()); - System.out.println("VALUES:hb_config " + hb_config.values()); - return hb_config; - } - - - - -} |