import org.junit.Test;
import org.opendaylight.controller.cluster.raft.DefaultConfigParamsImpl;
import org.opendaylight.controller.cluster.raft.RaftState;
-import org.opendaylight.controller.cluster.raft.base.messages.ElectionTimeout;
+import org.opendaylight.controller.cluster.raft.base.messages.TimeoutNow;
import org.opendaylight.controller.cluster.raft.messages.AppendEntriesReply;
import org.opendaylight.controller.cluster.raft.messages.RequestVote;
import org.opendaylight.controller.cluster.raft.messages.RequestVoteReply;
member3Actor.expectMessageClass(RequestVoteReply.class, 1);
member3Actor.expectMessageClass(AppendEntriesReply.class, 2);
- member3ActorRef.tell(new ElectionTimeout(), ActorRef.noSender());
+ member3ActorRef.tell(TimeoutNow.INSTANCE, ActorRef.noSender());
member3Actor.waitForExpectedMessages(RequestVoteReply.class);
member3Actor.dropMessagesToBehavior(RequestVote.class);
- member2ActorRef.tell(new ElectionTimeout(), ActorRef.noSender());
+ member2ActorRef.tell(TimeoutNow.INSTANCE, ActorRef.noSender());
member1Actor.waitForExpectedMessages(RequestVote.class);
member3Actor.waitForExpectedMessages(RequestVote.class);
member2Context.setConfigParams(member2ConfigParams);
member2Actor.behavior = new Follower(member2Context);
+ member2Context.setCurrentBehavior(member2Actor.behavior);
// Create member 3's behavior initially as Follower
member3Context.setConfigParams(member3ConfigParams);
member3Actor.behavior = new Follower(member3Context);
+ member3Context.setCurrentBehavior(member3Actor.behavior);
// Create member 1's behavior initially as Leader