X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Feos-dom-akka%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Feos%2Fakka%2FDataCentersTest.java;h=28566c7f15631a501aa92dde306d633171aba038;hp=440229e9b1b681c333825b5d278b1cdf2023aa2b;hb=refs%2Fchanges%2F81%2F95981%2F14;hpb=805e9821a737d305f7f591ae51055e475e26fcdc

diff --git a/opendaylight/md-sal/eos-dom-akka/src/test/java/org/opendaylight/controller/eos/akka/DataCentersTest.java b/opendaylight/md-sal/eos-dom-akka/src/test/java/org/opendaylight/controller/eos/akka/DataCentersTest.java
index 440229e9b1..28566c7f15 100644
--- a/opendaylight/md-sal/eos-dom-akka/src/test/java/org/opendaylight/controller/eos/akka/DataCentersTest.java
+++ b/opendaylight/md-sal/eos-dom-akka/src/test/java/org/opendaylight/controller/eos/akka/DataCentersTest.java
@@ -62,7 +62,7 @@ public class DataCentersTest extends AbstractNativeEosTest {
         registerCandidates(node3, ENTITY_1, "member-3");
         registerCandidates(node4, ENTITY_1, "member-4");
 
-        activateDatacenter(node1);
+        activateDatacenter(node1).get();
 
         waitUntillOwnerPresent(node1, ENTITY_1);
         final MockEntityOwnershipListener listener1 = registerListener(node1, ENTITY_1);
@@ -76,8 +76,8 @@ public class DataCentersTest extends AbstractNativeEosTest {
         verifyListenerState(listener1, ENTITY_1, false, false, true);
         verifyListenerState(listener2, ENTITY_1, false, false, false);
 
-        deactivateDatacenter(node1);
-        activateDatacenter(node4);
+        deactivateDatacenter(node1).get();
+        activateDatacenter(node4).get();
 
         verifyListenerState(listener1, ENTITY_1, true, false, false);
         verifyListenerState(listener2, ENTITY_1, true, true, false);
@@ -88,8 +88,8 @@ public class DataCentersTest extends AbstractNativeEosTest {
         verifyListenerState(listener1, ENTITY_1, true, false, false);
         verifyListenerState(listener2, ENTITY_1, true, false, true);
 
-        deactivateDatacenter(node3);
-        activateDatacenter(node2);
+        deactivateDatacenter(node3).get();
+        activateDatacenter(node2).get();
 
         // no candidate in dc-primary so no owners after datacenter activation
         verifyListenerState(listener1, ENTITY_1, false, false, false);
@@ -97,12 +97,12 @@ public class DataCentersTest extends AbstractNativeEosTest {
     }
 
     @Test
-    public void testDataCenterShutdown() {
+    public void testDataCenterShutdown() throws Exception {
         registerCandidates(node1, ENTITY_1, "member-1");
         registerCandidates(node3, ENTITY_1, "member-3");
         registerCandidates(node4, ENTITY_1, "member-4");
 
-        activateDatacenter(node1);
+        activateDatacenter(node1).get();
 
         waitUntillOwnerPresent(node1, ENTITY_1);
         final MockEntityOwnershipListener listener1 = registerListener(node1, ENTITY_1);
@@ -119,7 +119,7 @@ public class DataCentersTest extends AbstractNativeEosTest {
         ActorTestKit.shutdown(node1.getActorSystem(), Duration.ofSeconds(20));
         ActorTestKit.shutdown(node2.getActorSystem(), Duration.ofSeconds(20));
 
-        activateDatacenter(node3);
+        activateDatacenter(node3).get();
         verifyListenerState(listener2, ENTITY_1, true, true, false);
 
         unregisterCandidates(node3, ENTITY_1, "member-3");