1 files changed, 153 insertions, 0 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
new file mode 100644
index 0000000..9da7521
--- /dev/null
+++ b/veslibrary/ves_javalibrary/evel_javalib2/src/main/java/evel_javalibrary/att/com/loadbalance/heartBeatData.java
@@ -0,0 +1,153 @@
+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;
+	}
+
+	
+
+
+}