X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Forg%2Fonap%2Fclamp%2Floop%2Ftemplate%2FPolicyModelsService.java;h=98b9289169714aa1da68f0c2d9544bfb818a4f93;hb=afac3121bfacc4d81903b1d8492613b0b77d3298;hp=ae66c54b8063ad193ea55da6e091c60a8a9372cc;hpb=3c327c1fe313cb31dcc914dcaee7f38255240099;p=clamp.git

diff --git a/src/main/java/org/onap/clamp/loop/template/PolicyModelsService.java b/src/main/java/org/onap/clamp/loop/template/PolicyModelsService.java
index ae66c54b..98b92891 100644
--- a/src/main/java/org/onap/clamp/loop/template/PolicyModelsService.java
+++ b/src/main/java/org/onap/clamp/loop/template/PolicyModelsService.java
@@ -148,7 +148,7 @@ public class PolicyModelsService {
     public void createPolicyInDbIfNeeded(PolicyModel policyModel) {
         if (!policyModelsRepository.existsById(
             new PolicyModelId(policyModel.getPolicyModelType(), policyModel.getVersion()))) {
-            policyModelsRepository.save(policyModel);
+            policyModelsRepository.saveAndFlush(policyModel);
         }
     }
 
@@ -173,7 +173,7 @@ public class PolicyModelsService {
                 JsonObject supportedPdpJson = new JsonObject();
                 supportedPdpJson.add("supportedPdpGroups", supportedPdpGroups);
                 policyModel.setPolicyPdpGroup(supportedPdpJson);
-                policyModelsRepository.save(policyModel);
+                policyModelsRepository.saveAndFlush(policyModel);
             }
         }
     }