X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fraft%2Fbehaviors%2FAbstractLeaderElectionScenarioTest.java;h=8c7c9cb7c4a3ed640d5d04c0a58534a99a819abb;hp=137ea4a694891eb46292e4ddb6a99aad54e3b657;hb=51bf6c7493843ad23f074930b56925162732a8b2;hpb=c09801280b4c44f4ec26766e4d13b1a5d1f3ed59 diff --git a/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/behaviors/AbstractLeaderElectionScenarioTest.java b/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/behaviors/AbstractLeaderElectionScenarioTest.java index 137ea4a694..8c7c9cb7c4 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/behaviors/AbstractLeaderElectionScenarioTest.java +++ b/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/behaviors/AbstractLeaderElectionScenarioTest.java @@ -15,7 +15,9 @@ import akka.actor.ActorRef; import akka.actor.ActorSystem; import akka.actor.Props; import akka.actor.Status; +import akka.dispatch.ControlMessage; import akka.dispatch.Dispatchers; +import akka.dispatch.Mailboxes; import akka.pattern.Patterns; import akka.testkit.JavaTestKit; import akka.testkit.TestActorRef; @@ -56,7 +58,8 @@ public class AbstractLeaderElectionScenarioTest { CountDownLatch behaviorStateChangeLatch; public static Props props() { - return Props.create(MemberActor.class).withDispatcher(Dispatchers.DefaultDispatcherId()); + return Props.create(MemberActor.class).withDispatcher(Dispatchers.DefaultDispatcherId()) + .withMailbox(Mailboxes.DefaultMailboxId()); } @Override @@ -175,21 +178,21 @@ public class AbstractLeaderElectionScenarioTest { } } - static class SendImmediateHeartBeat { + static class SendImmediateHeartBeat implements ControlMessage { public static final SendImmediateHeartBeat INSTANCE = new SendImmediateHeartBeat(); private SendImmediateHeartBeat() { } } - static class GetBehaviorState { + static class GetBehaviorState implements ControlMessage { public static final GetBehaviorState INSTANCE = new GetBehaviorState(); private GetBehaviorState() { } } - static class SetBehavior { + static class SetBehavior implements ControlMessage { RaftActorBehavior behavior; MockRaftActorContext context;