2 files changed, 35 insertions, 5 deletions

diff --git a/src/test/java/org/onap/dcae/vestest/EventTransformTest.java b/src/test/java/org/onap/dcae/vestest/EventTransformTest.java
index 8a85117b..96e965cf 100644
--- a/src/test/java/org/onap/dcae/vestest/EventTransformTest.java
+++ b/src/test/java/org/onap/dcae/vestest/EventTransformTest.java
@@ -23,10 +23,8 @@ import static org.junit.Assert.assertEquals;
 
 import java.io.FileReader;
 import java.io.IOException;
-
 import org.json.JSONObject;
 import com.google.gson.JsonParser;
-
 import com.google.gson.JsonObject;
 import org.junit.Test;
 
@@ -63,7 +61,6 @@ public class EventTransformTest {
 		}
 		return jsonObject;
 	}
-
 	@Test
 	public void testAttrMap(){
 		
@@ -95,7 +92,23 @@ public class EventTransformTest {
 	 	System.out.println("responseData==" + responseData); 
 	 	assertEquals (alarmAdditionalInformation, responseData); 
 	}
-	
+	@Test
+	public void testJobjMaptoArray(){
+		
+		final JSONObject jsonObject = getFileAsJsonObject();
+		//final String receiveDiscards = (((jsonObject.getJSONObject("event")).getJSONObject("faultFields")).get("errors")).get("receiveDiscards").toString();
+		System.out.println("event==" + jsonObject.toString());
+		//System.out.println("alarmAdditionalInformation==" + alarmAdditionalInformation);
+		final JSONObject jsonArgs = new JSONObject ( "{\"field\": \"event.faultFields.vNicPerformanceArray[]\",\"oldField\": \"event.faultFields.errors\",\"attrMap\":{\"receiveDiscards\":\"receivedDiscardedPacketsAccumulated\"}}" );
+		ConfigProcessors cpEvent = new ConfigProcessors(jsonObject);
+		final String receiveDiscards = cpEvent.getEventObjectVal("event.faultFields.errors.receiveDiscards").toString();
+		System.out.println("receiveDiscards==" + receiveDiscards);
+	 	cpEvent.map(jsonArgs);
+	 	final String responseData = cpEvent.getEventObjectVal("event.faultFields.vNicPerformanceArray[0].receivedDiscardedPacketsAccumulated").toString();
+	 	System.out.println("modified event==" + jsonObject.toString());
+	 	System.out.println("responseData==" + responseData); 
+	 	assertEquals (receiveDiscards, responseData); 
+	}
 	@Test
 	public void testAttrAdd(){
 		
@@ -113,6 +126,22 @@ public class EventTransformTest {
 	}
 	
 	@Test
+	public void testAttrUpdate(){
+		
+		final JSONObject jsonObject = getFileAsJsonObject();
+		//final String functionRole = (jsonObject.getJSONObject("event")).getJSONObject("commonEventHeader").get("functionalRole").toString();
+		System.out.println("event==" + jsonObject.toString());
+		//System.out.println("functionRole==" + functionRole);
+		final JSONObject jsonArgs = new JSONObject ( "{\"field\": \"event.faultFields.version\",\"value\": \"2.0\",\"fieldType\": \"number\"}" );
+		ConfigProcessors cpEvent = new ConfigProcessors(jsonObject);
+	 	cpEvent.updateAttribute(jsonArgs);
+	 	final String responseData = cpEvent.getEventObjectVal("event.faultFields.version").toString();
+	 	System.out.println("modified event==" + jsonObject.toString());
+	 	System.out.println("responseData==" + responseData); 
+	 	assertEquals ("2.0", responseData); 
+	}
+	
+	@Test
 	public void testAttrConcatenate(){
 		
 		final JSONObject jsonObject = getFileAsJsonObject();
diff --git a/src/test/java/org/onap/dcae/vestest/TestCommonStartup.java b/src/test/java/org/onap/dcae/vestest/TestCommonStartup.java
index 06f70183..0cf90759 100644
--- a/src/test/java/org/onap/dcae/vestest/TestCommonStartup.java
+++ b/src/test/java/org/onap/dcae/vestest/TestCommonStartup.java
@@ -49,6 +49,7 @@ import com.att.nsa.drumlin.till.nv.impl.nvPropertiesFile;
 import com.att.nsa.drumlin.till.nv.impl.nvReadableStack;
 import com.att.nsa.drumlin.till.nv.impl.nvReadableTable;
 
+
 public class TestCommonStartup {
 
         String payload = null;
@@ -57,7 +58,7 @@ public class TestCommonStartup {
 
                 // process command line arguments
                 payload = new JsonParser().parse(new FileReader("src/test/resources/VES_valid.txt")).toString();
-                CommonStartup.fProcessingInputQueue = new LinkedBlockingQueue<JSONObject> (CommonStartup.kDefault_MaxQueuedEvents);
+                CommonStartup.fProcessingInputQueue = new LinkedBlockingQueue<JSONObject> (CommonStartup.KDEFAULT_MAXQUEUEDEVENTS);
         }
 
         @After