X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fraft%2Fbehaviors%2FPartitionedLeadersElectionScenarioTest.java;h=11cc1f0a6d87b70f49ba8482431dae46ca08555e;hb=24ace09aacc620fd9768e0a7004e802f9385bcfc;hp=d29a70735082f19b6fc66f898d561c55f2e7be65;hpb=2fb20e0091de8945147ca984721b23d28161aa8d;p=controller.git diff --git a/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/behaviors/PartitionedLeadersElectionScenarioTest.java b/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/behaviors/PartitionedLeadersElectionScenarioTest.java index d29a707350..11cc1f0a6d 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/behaviors/PartitionedLeadersElectionScenarioTest.java +++ b/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/behaviors/PartitionedLeadersElectionScenarioTest.java @@ -159,7 +159,7 @@ public class PartitionedLeadersElectionScenarioTest extends AbstractLeaderElecti member3Actor.dropMessagesToBehavior(AppendEntries.class); member3Actor.dropMessagesToBehavior(RequestVote.class); - member2ActorRef.tell(new ElectionTimeout(), ActorRef.noSender()); + member2ActorRef.tell(ElectionTimeout.INSTANCE, ActorRef.noSender()); member2Actor.waitForExpectedMessages(RequestVoteReply.class); @@ -207,7 +207,7 @@ public class PartitionedLeadersElectionScenarioTest extends AbstractLeaderElecti member3Actor.expectMessageClass(RequestVoteReply.class, 1); member3Actor.expectMessageClass(AppendEntriesReply.class, 1); - member3ActorRef.tell(new ElectionTimeout(), ActorRef.noSender()); + member3ActorRef.tell(ElectionTimeout.INSTANCE, ActorRef.noSender()); member1Actor.waitForExpectedMessages(RequestVote.class); member2Actor.waitForExpectedMessages(RequestVote.class); @@ -251,7 +251,7 @@ public class PartitionedLeadersElectionScenarioTest extends AbstractLeaderElecti member3Actor.dropMessagesToBehavior(RequestVote.class); - member2ActorRef.tell(new ElectionTimeout(), ActorRef.noSender()); + member2ActorRef.tell(ElectionTimeout.INSTANCE, ActorRef.noSender()); member1Actor.waitForExpectedMessages(RequestVote.class); member3Actor.waitForExpectedMessages(RequestVote.class); @@ -287,6 +287,7 @@ public class PartitionedLeadersElectionScenarioTest extends AbstractLeaderElecti member2Context.setConfigParams(member2ConfigParams); member2Actor.behavior = new Follower(member2Context); + member2Context.setCurrentBehavior(member2Actor.behavior); // Create member 3's behavior initially as Follower @@ -299,6 +300,7 @@ public class PartitionedLeadersElectionScenarioTest extends AbstractLeaderElecti member3Context.setConfigParams(member3ConfigParams); member3Actor.behavior = new Follower(member3Context); + member3Context.setCurrentBehavior(member3Actor.behavior); // Create member 1's behavior initially as Leader