Use akka-multi-dc in eos native

[controller.git] / opendaylight / md-sal / eos-dom-akka / src / test / java / org / opendaylight / controller / eos / akka / AkkaEntityOwnershipServiceTest.java

diff --git a/opendaylight/md-sal/eos-dom-akka/src/test/java/org/opendaylight/controller/eos/akka/AkkaEntityOwnershipServiceTest.java b/opendaylight/md-sal/eos-dom-akka/src/test/java/org/opendaylight/controller/eos/akka/AkkaEntityOwnershipServiceTest.java
index 0c4b5ea9f6b618339dd2f433d11365db85a29cf0..a444aefcfb277dc1520cdefb24461c2408c3a720 100644 (file)
--- a/opendaylight/md-sal/eos-dom-akka/src/test/java/org/opendaylight/controller/eos/akka/AkkaEntityOwnershipServiceTest.java
+++ b/opendaylight/md-sal/eos-dom-akka/src/test/java/org/opendaylight/controller/eos/akka/AkkaEntityOwnershipServiceTest.java
@@ -152,15 +152,15 @@ public class AkkaEntityOwnershipServiceTest extends AbstractNativeEosTest {
         registerCandidates(runningContext.getCandidateRegistry(), entity, "member-2");
 
         final ActorRef<OwnerSupervisorCommand> ownerSupervisor = runningContext.getOwnerSupervisor();
         registerCandidates(runningContext.getCandidateRegistry(), entity, "member-2");
 
         final ActorRef<OwnerSupervisorCommand> ownerSupervisor = runningContext.getOwnerSupervisor();

-        reachableMember(ownerSupervisor, "member-2");
-        unreachableMember(ownerSupervisor, "member-1");
+        reachableMember(ownerSupervisor, "member-2", DEFAULT_DATACENTER);
+        unreachableMember(ownerSupervisor, "member-1", DEFAULT_DATACENTER);

         verifyGetOwnershipState(service, entity, EntityOwnershipState.OWNED_BY_OTHER);
 
         final DOMEntity entity2 = new DOMEntity(ENTITY_TYPE, "two");
         final Optional<EntityOwnershipState> state = service.getOwnershipState(entity2);
         assertFalse(state.isPresent());
 
         verifyGetOwnershipState(service, entity, EntityOwnershipState.OWNED_BY_OTHER);
 
         final DOMEntity entity2 = new DOMEntity(ENTITY_TYPE, "two");
         final Optional<EntityOwnershipState> state = service.getOwnershipState(entity2);
         assertFalse(state.isPresent());
 

-        unreachableMember(ownerSupervisor, "member-2");
+        unreachableMember(ownerSupervisor, "member-2", DEFAULT_DATACENTER);

         verifyGetOwnershipState(service, entity, EntityOwnershipState.NO_OWNER);
     }
 
         verifyGetOwnershipState(service, entity, EntityOwnershipState.NO_OWNER);
     }