summaryrefslogtreecommitdiffstats
path: root/veslibrary/ves_javalibrary/evel_javalib2/src/test/java/TestJunit.java
diff options
context:
space:
mode:
Diffstat (limited to 'veslibrary/ves_javalibrary/evel_javalib2/src/test/java/TestJunit.java')
-rw-r--r--veslibrary/ves_javalibrary/evel_javalib2/src/test/java/TestJunit.java426
1 files changed, 65 insertions, 361 deletions
diff --git a/veslibrary/ves_javalibrary/evel_javalib2/src/test/java/TestJunit.java b/veslibrary/ves_javalibrary/evel_javalib2/src/test/java/TestJunit.java
index fe993ec..adab087 100644
--- a/veslibrary/ves_javalibrary/evel_javalib2/src/test/java/TestJunit.java
+++ b/veslibrary/ves_javalibrary/evel_javalib2/src/test/java/TestJunit.java
@@ -107,7 +107,7 @@ public class TestJunit {
}
}
-
+
@Test
public void testMain() {
Main mains = new Main();
@@ -119,7 +119,8 @@ public class TestJunit {
@Test
public void testLBHeartBeat() {
HeartBeatData hb = new HeartBeatData();
- hb.start();
+ hb.start();
+ hb.hostName();
}
@Test
@@ -127,7 +128,7 @@ public class TestJunit {
FaultData flDataThread = new FaultData();
new Thread(flDataThread.faultInstance01).start();
new Thread(flDataThread.faultInstance02).start();
-
+ flDataThread.hostName();
String[] strArray = {"name1","name12","name13"};
flDataThread.main(strArray);
}
@@ -136,7 +137,7 @@ public class TestJunit {
public void testLBMeasurement() {
MeasureData mdataThread = new MeasureData();
mdataThread.start();
-
+ mdataThread.hostName();
String[] strArra = {"meas1","meas1","meas1"};
mdataThread.main(strArra);
@@ -144,9 +145,14 @@ public class TestJunit {
}
@Test
- public void testLBSyslog() {
+ public void testLBSyslog() throws IOException {
syslogData syslogDataThread = new syslogData();
syslogDataThread.start();
+ syslogDataThread.syslogFileRead("INSECURE MODE");
+ syslogDataThread.hostName();
+ syslogDataThread.sendSysLogEvent("INSECURE MODE", "Jan 23 18:09:01 ves-VirtualBox cron[1119]: (*system*) INSECURE MODE (group/other writable) (/etc/crontab)");
+ String[] strArra = {"meas1"};
+ syslogDataThread.main(strArra);
}
@@ -162,6 +168,15 @@ public class TestJunit {
dd.setT1Bytesout("671940");
dd.setT1Packetsin("73017");
dd.setT1Packetsout("86180");
+ dd.getInstanceres02Command();
+ dd.getT0bytesIn();
+ dd.getT0bytesOut();
+ dd.getT0packetIn();
+ dd.getT0packetOut();
+ dd.getT1Bytesin();
+ dd.getT1Bytesout();
+ dd.getT1Packetsin();
+ dd.getT1Packetsout();
}
@@ -198,10 +213,10 @@ public class TestJunit {
EVEL_ENTITY_STATE.EVEL_ENTITY_STATE_OUT_OF_SERVICE,"bgp");
stc.evel_statechange_addl_info_add("bgpa", "fail");
stc.evel_statechange_addl_info_add("bgpb", "fail");
- when(mymainmock.evel_post_event(stc)).thenReturn(true);
- boolean ret = mymainmock.evel_post_event(stc);
- LOG.info("Returned "+ret);
- assertTrue( ret );
+
+
+ stc.evel_json_encode_event();
+ stc.evel_json_encode_event_batch();
}
@@ -212,7 +227,7 @@ public class TestJunit {
header = EvelHeader.evel_new_heartbeat("Hearbeat_vAFX","vmname_ip");
header.evel_nfnamingcode_set("vVNF");
header.evel_nfcnamingcode_set("vVNF");
- header.evel_timeZoneOffset_set("UTC+5:30");
+ header.evel_timeZoneOffset_set("UTC+5:30");
when(mymainmock.evel_post_event(header)).thenReturn(true);
boolean ret = mymainmock.evel_post_event(header);
LOG.info("Returned "+ret);
@@ -225,10 +240,9 @@ public class TestJunit {
EvelHeartbeatField hfld = new EvelHeartbeatField(123,"HeartbeatField_vVNF", "1");
hfld.evel_hrtbt_interval_set(100);
hfld.evel_timeZoneOffset_set("UTC+5:30");
- when(mymainmock.evel_post_event(hfld)).thenReturn(true);
- boolean ret = mymainmock.evel_post_event(hfld);
- LOG.info("Returned "+ret);
- assertTrue( ret );
+
+ hfld.evel_json_encode_event();
+ hfld.evel_json_encode_event_batch();
}
@@ -247,305 +261,18 @@ public class TestJunit {
flt.evel_fault_type_set("vmintf");
flt.evel_fault_interface_set("My Interface Card");
flt.evel_fault_category_set("link");
- when(mymainmock.evel_post_event(flt)).thenReturn(true);
- boolean ret = mymainmock.evel_post_event(flt);
- LOG.info("Returned "+ret);
- assertTrue( ret );
+
+ flt.evel_json_encode_event();
+ flt.evel_json_encode_event_batch();
}
@Test
public void testBatch() {
EvelBatch be = new EvelBatch();
- EvelFault flt2 = new EvelFault("Fault_vVNF", "vmname_ip",
- "NIC error", "Hardware failed",
- EvelHeader.PRIORITIES.EVEL_PRIORITY_HIGH,
- EVEL_SEVERITIES.EVEL_SEVERITY_MAJOR,
- EVEL_SOURCE_TYPES.EVEL_SOURCE_CARD,
- EVEL_VF_STATUSES.EVEL_VF_STATUS_ACTIVE);
- flt2.evel_fault_addl_info_add("nichw", "fail");
- flt2.evel_fault_addl_info_add("nicsw", "fail");
- be.addEvent(flt2);
- EvelFault flt3 = new EvelFault("Fault_vVNF", "vmname_ip2",
- "NIC error", "Hardware failed",
- EvelHeader.PRIORITIES.EVEL_PRIORITY_NORMAL,
- EVEL_SEVERITIES.EVEL_SEVERITY_MAJOR,
- EVEL_SOURCE_TYPES.EVEL_SOURCE_CARD,
- EVEL_VF_STATUSES.EVEL_VF_STATUS_ACTIVE);
- flt3.evel_fault_type_set("Interface fault");
- flt3.evel_fault_category_set("Failed category");
- flt3.evel_fault_interface_set("An Interface Card");
- flt3.evel_fault_addl_info_add("nichw", "fail");
- flt3.evel_fault_addl_info_add("nicsw", "fail");
- be.addEvent(flt3);
-
-
- EvelStateChange stc = new EvelStateChange("StateChange_vVNF", "vmname_ip",
- EVEL_ENTITY_STATE.EVEL_ENTITY_STATE_IN_SERVICE,
- EVEL_ENTITY_STATE.EVEL_ENTITY_STATE_OUT_OF_SERVICE,"bgp");
- stc.evel_statechange_addl_info_add("bgpa", "fail");
- stc.evel_statechange_addl_info_add("bgpb", "fail");
- //AgentMain.evel_post_event(stc);
- be.addEvent(stc);
+ be.evel_json_encode_event();
-
- EvelSyslog sysl = new EvelSyslog("Syslog_vVNF", "vmname_ip",
- EvelFault.EVEL_SOURCE_TYPES.EVEL_SOURCE_ROUTER,
- "Router failed","JUNIPER");
- sysl.evel_syslog_event_source_host_set("SL Host");
- sysl.evel_syslog_priority_set(21);
- sysl.evel_syslog_proc_id_set(456);
- sysl.evel_syslog_proc_set("routed");
- sysl.evel_syslog_s_data_set("sys data");
- sysl.evel_syslog_sdid_set("200");
- sysl.evel_syslog_severity_set("Alert");
- sysl.evel_syslog_facility_set(EVEL_SYSLOG_FACILITIES.EVEL_SYSLOG_FACILITY_INTERNAL);
- sysl.evel_syslog_severity_set("Data");
- sysl.evel_syslog_version_set(20);
- sysl.evel_syslog_msghost_set("Hostmsg");
- sysl.evel_syslogTs_set("SyslogTs");
- sysl.evel__syslog_addl_info_add("name1", "value1");
- sysl.evel__syslog_addl_info_add("name2", "value2");
- be.addEvent(sysl);
-
-
- EvelNotification notification = new EvelNotification("Notification_vVNF", "vmname_ip","change_identifier", "configuration changed");
- notification.evel_notification_add_newState_set("maintainance");
- notification.evel_notification_add_oldState_set("out of Service");
- notification.evel_notification_add_changeContact_set("ChangeContact");
- notification.evel_notification_addl_info_add("name1", "value1");
- notification.evel_notification_addl_info_add("name4", "value5");
- notification.evel_notification_add_namedarray("hmNam1", "hmName1", "hmNmae2");
- notification.evel_notification_add_stateInterface_set("StateChange");
- be.addEvent(notification);
-
-
-
- EvelPnfRegistration pnfRegistration = new EvelPnfRegistration("PnfRegistration_vVNF", "vmname_ip");
- pnfRegistration.evel_pnrregistration_add_lastServiceDate_set("10FEB2019");
- pnfRegistration.evel_pnrregistration_add_modelNumber_set("123456789");
- pnfRegistration.evel_pnfRegistration_serialNumber_set("6061ZW3");
- pnfRegistration.evel_pnrregistration_add_macaddress_set("localhost");
- pnfRegistration.evel_pnrregistration_add_manufactureDate_set("FEB2011");
- pnfRegistration.evel_pnrregistration_add_oamV4IpAddress_set("localhost");
-
- pnfRegistration.evel_pnfRegistration_softwareVersion_set("SW1234");
-
-
- pnfRegistration.evel_pnfRegistration_unitFamily_set("unitFamily222");
- pnfRegistration.evel_pnfRegistration_unitType_set("unitType1");
-
- pnfRegistration.evel_pnrregistration_add_oamV4IpAddress_set("localhost");
- pnfRegistration.evel_pnrregistration_add_oamV6IpAddress_set("localhost");
-
-
- pnfRegistration.evel_pnfRegistration_vendorName_set("Vend_nam_123");
- pnfRegistration.evel_pnrregistration_addl_info_add("Name1", "value1");
- pnfRegistration.evel_pnrregistration_addl_info_add("Name2", "value2");
- be.addEvent(pnfRegistration);
-
- EvelSipSignaling sip = new EvelSipSignaling("SipSignaling_vVNF", "vmname_ip","aricent","corlator","localhost","5647","localhost","5678");
- sip.evel_signaling_vnfmodule_name_set("nfName");
- sip.evel_signaling_vnfname_set("nf_name");
- sip.evel_signaling_addl_info_add("name1", "value1");
- sip.evel_signaling_addl_info_add("name2", "value2");
- sip.evel_signaling_compressed_sip_set("CompressedIP");
- sip.evel_signaling_summary_sip_set("SummarySip");
- be.addEvent(sip);
-
- EvelVoiceQuality vq = new EvelVoiceQuality("VoiceQuality_vVNF", "vmname_ip",
- "calleeSideCodc",
- "callerSideCodc", "corlator",
- "midCllRtcp", "juniper");
- vq.evel_voice_quality_end_metrics_set("adjname", "Caller", 20, 30, 40, 50, 60, 70, 80, 100, 110, 120, 130, 140, 1.1, 160.12, 17, 190, 200,210,220,230,240,250,260,270,280,290,300);
- vq.evel_voice_quality_phone_number_set("PhoneNumber");
- vq.evel_voice_quality_vnfmodule_name_set("vnfNaming");
- vq.evel_voice_quality_vnfname_set("vnfName");
- vq.evel_voice_quality_addl_info_add("Name1", "value1");
- vq.evel_voice_quality_addl_info_add("Name2", "value2");
- be.addEvent(vq);
-
- EvelOther ev = new EvelOther("MyCustomEvent_vVNF", "vmname_ip");
- ev.evel_other_field_add("name1", "value1");
- ev.evel_other_field_add("name2", "value2");
- ev.evel_other_field_add("name3", "value3");
- ev.evel_other_field_add("name4", "value4");
-
- ev.evel_other_field_add_namedarray("value3", "name3", "value6");
- ev.evel_other_field_add_namedarray("value1", "name4", "value7");
- ev.evel_other_field_add_namedarray("value1", "name4", "value7");
- ev.evel_other_field_add_namedarray("value4", "name5", "value8");
-
-
- JsonObjectBuilder jsonObjBld =
- Json.createObjectBuilder()
- .add("trackIdentifier", 12345)
- .add("remoteSource", "vm1235")
- .add("ended", "12:45:67")
- .add("detached", 633453)
- .add("frameWidth", 765765)
- .add("frameHeight", 767867)
- .add("framesPerSecond", 334343)
- .add("framesSent", 8976786)
- .add("framesReceived", 233423)
- .add("frameHeight", 8897896)
- .add("framesDecoded", 3434533)
- .add("framesDropped", 87867676)
- .add("framesCorrupted", 3345342)
- .add("audioLevel", "-45dBm");
- JsonObject custom = jsonObjBld.build();
-
- ev.evel_other_field_add_jsonobj(custom);
- be.addEvent(ev);
-
- String dateStart = "01/14/2012 09:29:58";
- String dateStop = "01/15/2012 10:31:48";
-
- //HH converts hour in 24 hours format (0-23), day calculation
- SimpleDateFormat format = new SimpleDateFormat("MM/dd/yyyy HH:mm:ss");
-
- Date d1 = null;
- Date d2 = null;
-
- try {
- d1 = format.parse(dateStart);
- d2 = format.parse(dateStop);
- }catch (Exception e) {
-
- }
-
- EvelThresholdCross tca = new EvelThresholdCross("ThresholdCross_vVNF", "vmname_ip", "CRIT",
- "mcastRxPackets", EvelThresholdCross.EVEL_EVENT_ACTION.EVEL_EVENT_ACTION_CLEAR,
- "Mcast Rx breached",
- EvelThresholdCross.EVEL_ALERT_TYPE.EVEL_CARD_ANOMALY,
-
- d1, EvelThresholdCross.EVEL_SEVERITIES.EVEL_SEVERITY_CRITICAL,
- d2);
-
- tca.evel_threshold_cross_alertvalue_set("alertvalue");
- tca.evel_threshold_cross_data_collector_set("data_collector");
- tca.evel_threshold_cross_data_elementtype_set("data_elementtype");
- tca.evel_threshold_cross_interfacename_set("interfacename");
- tca.evel_threshold_cross_networkservice_set("networkservice");
- tca.evel_threshold_cross_possible_rootcause_set("possible_rootcause");
-
- tca.evel_thresholdcross_addl_info_add("addname1", "addvalue1");
- tca.evel_thresholdcross_addl_info_add("addname2", "addvalue2");
- tca.evel_thresholdcross_alertid_add("alert1");
- tca.evel_thresholdcross_alertid_add("alert2");
- tca.evel_thresholdcross_alertid_add("alert3");
- tca.evel_thresholdcross_hashMap_add("hashName", "hashValue");
- be.addEvent(tca);
-
-
-
-
- try {
- d1 = format.parse(dateStart);
- }catch (Exception e) {
-
- }
- EvelMobileFlow mf = new EvelMobileFlow("MobileFlow_vVNF", "vmname_ip",
- "In",
- null,
- "GTP",
- "v2.3",
- "localhost",
- 345556,
- "localhost",
- 334344);
- MOBILE_GTP_PER_FLOW_METRICS mygtp = mf.new MOBILE_GTP_PER_FLOW_METRICS(
- 1.01,
- 2.02,
- 3,
- 4,
- 5,
- 6,
- 7,
- 8,
- 9,
- d1,
- "ACTIVE",
- 10,
- 11,
- 12,
- 13,
- 14,
- 15,
- 16,
- 17,
- 18,
- 19,
- 20,
- 21,
- 22,
- 23,
- 24,
- 25,
- 26,
- 27,
- 28);
- mf.gtp_per_flow_metrics = mygtp;
-
-
- mf.evel_mobile_gtp_metrics_dur_con_fail_set(mygtp, 1);
- mf.evel_mobile_gtp_metrics_dur_tun_fail_set(mygtp, 1);
- mf.evel_mobile_gtp_metrics_act_by_set(mygtp, "Active");
- mf.evel_mobile_gtp_metrics_act_time_set(mygtp, "Time");
- mf.evel_mobile_gtp_metrics_deact_by_set(mygtp, "FlowDeactivation");
- mf.evel_mobile_gtp_metrics_con_status_set(mygtp, "Status");
- mf.evel_mobile_gtp_metrics_tun_status_set(mygtp, "Tunnel Status");
- mf.evel_mobile_gtp_metrics_large_pkt_rtt_set(mygtp, 12);
- mf.evel_mobile_gtp_metrics_large_pkt_thresh_set(mygtp, 123);
- mf.evel_mobile_gtp_metrics_max_rcv_bit_rate_set(mygtp, 12);
- mf.evel_mobile_gtp_metrics_max_trx_bit_rate_set(mygtp, 12);
- mf.evel_mobile_gtp_metrics_num_echo_fail_set(mygtp, 1);
- mf.evel_mobile_gtp_metrics_num_tun_fail_set(mygtp, 2);
- mf.evel_mobile_gtp_metrics_num_http_errors_set(mygtp, 2);
-
- mf.evel_mobile_gtp_metrics_iptos_set(mygtp,2, 3);
- mf.evel_mobile_gtp_metrics_iptos_set(mygtp,5, 6);
-
- mf.evel_mobile_gtp_metrics_tcp_flag_count_add(mygtp, 3, 4);
- mf.evel_mobile_gtp_metrics_tcp_flag_count_add(mygtp, 5, 8);
-
- mf.evel_mobile_gtp_metrics_qci_cos_count_add(mygtp, 2, 3);
- mf.evel_mobile_gtp_metrics_qci_cos_count_add(mygtp, 5, 6);
- mf.evel_mobile_flow_addl_field_add("mobileFlowName1", "mobileValue1");
- mf.evel_mobile_flow_app_type_set("application type");
- mf.evel_mobile_flow_app_prot_type_set("appProtocolType");
- mf.evel_mobile_flow_app_prot_ver_set("appProtocolVersion");
- mf.evel_mobile_flow_cid_set("CID");
- mf.evel_mobile_flow_con_type_set("ConnectionType");
- mf.evel_mobile_flow_ecgi_set("ECGI");
- mf.evel_mobile_flow_gtp_prot_type_set("gtpProtocalType");
- mf.evel_mobile_flow_gtp_prot_ver_set("GtpVersion");
- mf.evel_mobile_flow_http_header_set("HttpHeader");
- mf.evel_mobile_flow_imei_set("IMEI");
- mf.evel_mobile_flow_imsi_set("IMSI");
- mf.evel_mobile_flow_lac_set("LAC");
- mf.evel_mobile_flow_mcc_set("MCC");
- mf.evel_mobile_flow_mnc_set("MNC");
- mf.evel_mobile_flow_msisdn_set("Msisdn");
- mf.evel_mobile_flow_other_func_role_set("OtherFunctionRole");
-
- mf.evel_mobile_flow_rac_set("RAC");
- mf.evel_mobile_flow_radio_acc_tech_set("RadoiAcessTech");
- mf.evel_mobile_flow_sac_set("SAC");
-
- mf.evel_mobile_flow_samp_alg_set(123);
- mf.evel_mobile_flow_tac_set("TAC");
- mf.evel_mobile_flow_tunnel_id_set("Tunnel");
- mf.evel_mobile_flow_vlan_id_set("Vlan");
- be.addEvent(mf);
-
-
-
- when(mymainmock.evel_post_event(be)).thenReturn(true);
- boolean ret = mymainmock.evel_post_event(be);
- LOG.info("Returned "+ret);
- assertTrue( ret );
}
@@ -838,10 +565,9 @@ public class TestJunit {
sm.evel_measurement_vnic_performance_add("vnic","vals",0., 1.,2.,3.,4.,5.,6.,7.,8.,9.,10.,11.,12.,13.,14.,15.,16.,17.,18.,19.,20.,21.,22.,23.,24.,25.,26.,27.,28.,"administrativeState","operationalState",31.,32.,33.,34.,35.,36.);
- when(mymainmock.evel_post_event(sm)).thenReturn(true);
- boolean ret = mymainmock.evel_post_event(sm);
- LOG.info("Returned "+ret);
- assertTrue( ret );
+ sm.evel_json_encode_event();
+ sm.evel_json_encode_event_batch();
+
}
@Test
@@ -867,11 +593,10 @@ public class TestJunit {
sysl.evel__syslog_addl_info_add("name1", "value1");
sysl.evel__syslog_addl_info_add("name2", "value2");
+
+ sysl.evel_json_encode_event();
+ sysl.evel_json_encode_event_batch();
- when(mymainmock.evel_post_event(sysl)).thenReturn(true);
- boolean ret = mymainmock.evel_post_event(sysl);
- LOG.info("Returned "+ret);
- assertTrue( ret );
}
@@ -891,11 +616,10 @@ public class TestJunit {
mf.evel_mobile_flow_type_set("named");
mf.evel_mobile_flow_app_type_set("named");
mf.evel_mobile_flow_addl_field_add("Name", "Value");
-
- when(mymainmock.evel_post_event(mf)).thenReturn(true);
- boolean ret = mymainmock.evel_post_event(mf);
- LOG.info("Returned "+ret);
- assertTrue( ret );
+
+
+ mf.evel_json_encode_event();
+ mf.evel_json_encode_event_batch();
}
@@ -914,10 +638,9 @@ public class TestJunit {
notification.evel_notification_add_stateInterface_set("StateChange");
- when(mymainmock.evel_post_event(notification)).thenReturn(true);
- boolean ret = mymainmock.evel_post_event(notification);
- LOG.info("Returned "+ret);
- assertTrue( ret );
+ notification.evel_json_encode_event();
+ notification.evel_json_encode_event_batch();
+
}
@Test
@@ -930,7 +653,7 @@ public class TestJunit {
pnfRegistration.evel_pnfRegistration_serialNumber_set("6061ZW3");
pnfRegistration.evel_pnrregistration_add_macaddress_set("localhost");
pnfRegistration.evel_pnrregistration_add_manufactureDate_set("FEB2011");
- // pnfRegistration.evel_pnrregistration_add_modelNumber_set("FE934567");
+
pnfRegistration.evel_pnrregistration_add_oamV4IpAddress_set("localhost");
pnfRegistration.evel_pnfRegistration_softwareVersion_set("SW1234");
@@ -947,12 +670,8 @@ public class TestJunit {
pnfRegistration.evel_pnrregistration_addl_info_add("Name1", "value1");
pnfRegistration.evel_pnrregistration_addl_info_add("Name2", "value2");
-
-
- when(mymainmock.evel_post_event(pnfRegistration)).thenReturn(true);
- boolean ret = mymainmock.evel_post_event(pnfRegistration);
- LOG.info("Returned "+ret);
- assertTrue( ret );
+ pnfRegistration.evel_json_encode_event();
+ pnfRegistration.evel_json_encode_event_batch();
}
@@ -969,11 +688,9 @@ public class TestJunit {
sip.evel_signaling_addl_info_add("name2", "value2");
sip.evel_signaling_compressed_sip_set("CompressedIP");
sip.evel_signaling_summary_sip_set("SummarySip");
-
- when(mymainmock.evel_post_event(sip)).thenReturn(true);
- boolean ret = mymainmock.evel_post_event(sip);
- LOG.info("Returned "+ret);
- assertTrue( ret );
+
+ sip.evel_json_encode_event();
+ sip.evel_json_encode_event_batch();
}
@@ -991,16 +708,9 @@ public class TestJunit {
vq.evel_voice_quality_vnfname_set("vnfName");
vq.evel_voice_quality_addl_info_add("Name1", "value1");
vq.evel_voice_quality_addl_info_add("Name2", "value2");
- /*
- * Arguments updated 15/07/2018
- */
-
- // vq.evel_voice_quality_end_metrics_set("name","descr",2.,3.,4.,5.,6.,7.,8.,9.,10.,11.,12,13.,14.,15.,16.,17.,19.,20.,21.,22.,23.,24.,25.,26.,27.,28.,29.,30.);
-
- when(mymainmock.evel_post_event(vq)).thenReturn(true);
- boolean ret = mymainmock.evel_post_event(vq);
- LOG.info("Returned "+ret);
- assertTrue( ret );
+
+ vq.evel_json_encode_event();
+ vq.evel_json_encode_event_batch();
}
@Test
@@ -1037,10 +747,9 @@ public class TestJunit {
ev.evel_other_field_add_jsonobj(custom);
- when(mymainmock.evel_post_event(ev)).thenReturn(true);
- boolean ret = mymainmock.evel_post_event(ev);
- LOG.info("Returned "+ret);
- assertTrue( ret );
+ ev.evel_json_encode_event();
+ ev.evel_json_encode_event_batch();
+
}
@Test
@@ -1082,11 +791,9 @@ public class TestJunit {
tca.evel_thresholdcross_alertid_add("alert2");
tca.evel_thresholdcross_alertid_add("alert3");
tca.evel_thresholdcross_hashMap_add("hashName", "hashValue");
-
- when(mymainmock.evel_post_event(tca)).thenReturn(true);
- boolean ret = mymainmock.evel_post_event(tca);
- LOG.info("Returned "+ret);
- assertTrue( ret );
+
+ tca.evel_json_encode_event();
+ tca.evel_json_encode_event_batch();
}
@@ -1140,9 +847,7 @@ public class TestJunit {
26,
27,
28);
- mf.gtp_per_flow_metrics = mygtp;
-
-
+ mf.gtp_per_flow_metrics = mygtp;
mf.evel_mobile_gtp_metrics_dur_con_fail_set(mygtp, 1);
mf.evel_mobile_gtp_metrics_dur_tun_fail_set(mygtp, 1);
mf.evel_mobile_gtp_metrics_act_by_set(mygtp, "Active");
@@ -1192,11 +897,10 @@ public class TestJunit {
mf.evel_mobile_flow_tac_set("TAC");
mf.evel_mobile_flow_tunnel_id_set("Tunnel");
mf.evel_mobile_flow_vlan_id_set("Vlan");
-
- when(mymainmock.evel_post_event(mf)).thenReturn(true);
- boolean ret = mymainmock.evel_post_event(mf);
- LOG.info("Returned "+ret);
- assertTrue( ret );
+
+ mf.evel_json_encode_event();
+ mf.evel_json_encode_event_batch();
+
}