Code Review
/
clamp.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Fix the policy synchro
[clamp.git]
/
src
/
main
/
java
/
org
/
onap
/
clamp
/
clds
/
client
/
PolicyEngineServices.java
diff --git
a/src/main/java/org/onap/clamp/clds/client/PolicyEngineServices.java
b/src/main/java/org/onap/clamp/clds/client/PolicyEngineServices.java
index
44abc9d
..
2358671
100644
(file)
--- a/
src/main/java/org/onap/clamp/clds/client/PolicyEngineServices.java
+++ b/
src/main/java/org/onap/clamp/clds/client/PolicyEngineServices.java
@@
-27,12
+27,10
@@
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFManager;
import com.google.gson.JsonArray;
import com.google.gson.JsonObject;
import com.att.eelf.configuration.EELFManager;
import com.google.gson.JsonArray;
import com.google.gson.JsonObject;
-import java.util.ArrayList;
import java.util.Iterator;
import java.util.LinkedHashMap;
import java.util.LinkedList;
import java.util.List;
import java.util.Iterator;
import java.util.LinkedHashMap;
import java.util.LinkedList;
import java.util.List;
-import java.util.Map;
import org.apache.camel.CamelContext;
import org.apache.camel.Exchange;
import org.apache.camel.builder.ExchangeBuilder;
import org.apache.camel.CamelContext;
import org.apache.camel.Exchange;
import org.apache.camel.builder.ExchangeBuilder;
@@
-118,15
+116,12
@@
public class PolicyEngineServices {
return;
}
return;
}
- Li
st<LinkedHashMap<String, Object>> policyTypesList = (List<LinkedHashMap<String, Object>
>) loadedYaml
+ Li
nkedHashMap<String, Object> policyTypesMap = (LinkedHashMap<String, Object
>) loadedYaml
.get("policy_types");
.get("policy_types");
- policyTypesList.parallelStream().forEach(policyType -> {
- Map.Entry<String, Object> policyTypeEntry =
- (Map.Entry<String, Object>) new ArrayList(policyType.entrySet()).get(0);
-
+ policyTypesMap.entrySet().parallelStream().forEach(entryPolicyType -> {
policyModelsService.createPolicyInDbIfNeeded(
policyModelsService.createPolicyInDbIfNeeded(
- createPolicyModelFromPolicyEngine(
policyTypeEntry
.getKey(),
- ((String) ((LinkedHashMap<String, Object>)
policyTypeEntry
.getValue()).get("version"))));
+ createPolicyModelFromPolicyEngine(
entryPolicyType
.getKey(),
+ ((String) ((LinkedHashMap<String, Object>)
entryPolicyType
.getValue()).get("version"))));
});
}
});
}