import static org.onap.policy.m2.test.Util.json;
 
 import com.google.gson.JsonObject;
-
 import java.io.File;
 import java.time.Duration;
 import java.util.Properties;
 import java.util.UUID;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicReference;
-
 import org.awaitility.Durations;
 import org.junit.AfterClass;
 import org.junit.BeforeClass;
 import org.junit.Test;
-
 import org.onap.policy.drools.system.PolicyController;
 import org.onap.policy.drools.system.PolicyEngineConstants;
 import org.onap.policy.drools.util.KieUtils;
         dcae.send(req.msg);
 
         // receive active notification, and restart operation
-        awaitAndAssert(5, Durations.TWO_HUNDRED_MILLISECONDS, notification,
+        awaitAndAssert(10, Durations.TWO_HUNDRED_MILLISECONDS, notification,
             json("notification", "ACTIVE"));
 
         appcOperation(req, "Restart", 400, "Restart Successful");
         dcae.send(req.msg);
 
         // receive final success notification
-        awaitAndAssert(5, Durations.TWO_HUNDRED_MILLISECONDS, notification,
+        awaitAndAssert(10, Durations.TWO_HUNDRED_MILLISECONDS, notification,
                 json("notification", "FINAL: SUCCESS"));
 
         // sleep to allow DB update
         dcae.send(req.msg);
 
         // active notification, and restart 1 operation
-        awaitAndAssert(5, Durations.TWO_HUNDRED_MILLISECONDS, notification,
+        awaitAndAssert(10, Durations.TWO_HUNDRED_MILLISECONDS, notification,
                 json("notification", "ACTIVE"));
 
         appcOperation(req, "Restart", 450, "Restart 1 Failed");
         dcae.send(req.msg);
 
         // receive final success notification
-        awaitAndAssert(5, Durations.TWO_HUNDRED_MILLISECONDS, notification,
+        awaitAndAssert(10, Durations.TWO_HUNDRED_MILLISECONDS, notification,
                 json("notification", "FINAL: SUCCESS"));
 
         // sleep to allow DB update