summaryrefslogtreecommitdiffstats
path: root/veslibrary/ves_javalibrary/evel_javalib2/src/main/java/evel_javalibrary/att/com/loadbalance/heartBeatData.java
diff options
context:
space:
mode:
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.java153
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;
- }
-
-
-
-
-}