X-Git-Url: https://gerrit.onap.org/r/gitweb?p=policy%2Fengine.git;a=blobdiff_plain;f=PolicyEngineAPI%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fpolicy%2Fstd%2FNotificationUnMarshal.java;h=447e7cb26ac78637faff156baece4ad936da810e;hp=2ec174c84fa76ce4f9cd90e3fdd4db807af2ca1b;hb=80f072f60509ef3a35369a60857fe05f6c2a993a;hpb=c53fa990ea27ec074859eb94bcb7ec6deaa2157b

diff --git a/PolicyEngineAPI/src/main/java/org/onap/policy/std/NotificationUnMarshal.java b/PolicyEngineAPI/src/main/java/org/onap/policy/std/NotificationUnMarshal.java
index 2ec174c84..447e7cb26 100644
--- a/PolicyEngineAPI/src/main/java/org/onap/policy/std/NotificationUnMarshal.java
+++ b/PolicyEngineAPI/src/main/java/org/onap/policy/std/NotificationUnMarshal.java
@@ -20,49 +20,45 @@
 
 package org.onap.policy.std;
 
+import java.io.IOException;
 import java.util.ArrayList;
 import java.util.Collection;
 
 import org.onap.policy.api.LoadedPolicy;
 import org.onap.policy.api.RemovedPolicy;
 import org.onap.policy.api.UpdateType;
-import org.onap.policy.std.StdLoadedPolicy;
-import org.onap.policy.std.StdPDPNotification;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
 
 public class NotificationUnMarshal {
-	private static StdPDPNotification notification;
 	
-	public static StdPDPNotification notificationJSON(String json) throws Exception{
+	public static StdPDPNotification notificationJSON(String json) throws IOException{
 		ObjectMapper mapper = new ObjectMapper();
-		notification = mapper.readValue(json, StdPDPNotification.class);
-		if(notification!=null){
-			if(notification.getLoadedPolicies()!=null){
-				Collection<StdLoadedPolicy> stdLoadedPolicies = new ArrayList<>();
-				for(LoadedPolicy loadedPolicy: notification.getLoadedPolicies()){
-					StdLoadedPolicy stdLoadedPolicy = (StdLoadedPolicy) loadedPolicy;
-					if(notification.getRemovedPolicies()!=null){
-						Boolean updated = false;
-						for(RemovedPolicy removedPolicy: notification.getRemovedPolicies()){
-							String regex = ".(\\d)*.xml";
-							if(removedPolicy.getPolicyName().replaceAll(regex, "").equals(stdLoadedPolicy.getPolicyName().replaceAll(regex, ""))){
-								updated  = true;
-								break;
-							}
-						}
-						if(updated){
-							stdLoadedPolicy.setUpdateType(UpdateType.UPDATE);
-						}else{
-							stdLoadedPolicy.setUpdateType(UpdateType.NEW);
-						}
-					}else{
-						stdLoadedPolicy.setUpdateType(UpdateType.NEW);
-					}
-					stdLoadedPolicies.add(stdLoadedPolicy);
-				}
-				notification.setLoadedPolicies(stdLoadedPolicies);
-			}
+		StdPDPNotification notification = mapper.readValue(json, StdPDPNotification.class);
+		if(notification!=null&&notification.getLoadedPolicies()!=null){
+		    Collection<StdLoadedPolicy> stdLoadedPolicies = new ArrayList<>();
+		    for(LoadedPolicy loadedPolicy: notification.getLoadedPolicies()){
+		        StdLoadedPolicy stdLoadedPolicy = (StdLoadedPolicy) loadedPolicy;
+		        if(notification.getRemovedPolicies()!=null){
+		            Boolean updated = false;
+		            for(RemovedPolicy removedPolicy: notification.getRemovedPolicies()){
+		                String regex = ".(\\d)*.xml";
+		                if(removedPolicy.getPolicyName().replaceAll(regex, "").equals(stdLoadedPolicy.getPolicyName().replaceAll(regex, ""))){
+		                    updated  = true;
+		                    break;
+		                }
+		            }
+		            if(updated){
+		                stdLoadedPolicy.setUpdateType(UpdateType.UPDATE);
+		            }else{
+		                stdLoadedPolicy.setUpdateType(UpdateType.NEW);
+		            }
+		        }else{
+		            stdLoadedPolicy.setUpdateType(UpdateType.NEW);
+		        }
+		        stdLoadedPolicies.add(stdLoadedPolicy);
+		    }
+		    notification.setLoadedPolicies(stdLoadedPolicies);
 		}
 		return notification;
 	}