import static org.opendaylight.controller.cluster.raft.utils.MessageCollectorActor.expectFirstMatching;
import static org.opendaylight.controller.cluster.raft.utils.MessageCollectorActor.expectMatching;
-import akka.actor.Actor;
import akka.actor.ActorRef;
-import akka.actor.Props;
-import akka.testkit.TestActorRef;
import com.google.common.collect.ImmutableMap;
import java.util.List;
import java.util.concurrent.TimeUnit;
*/
public class PreLeaderScenarioTest extends AbstractRaftActorIntegrationTest {
- private TestActorRef<Actor> follower1NotifierActor;
+ private ActorRef follower1NotifierActor;
private DefaultConfigParamsImpl followerConfigParams;
@Test
- public void testUnComittedEntryOnLeaderChange() throws Exception {
+ public void testUnComittedEntryOnLeaderChange() {
testLog.info("testUnComittedEntryOnLeaderChange starting");
createRaftActors();
private void createRaftActors() {
testLog.info("createRaftActors starting");
- follower1NotifierActor = factory.createTestActor(Props.create(MessageCollectorActor.class),
+ follower1NotifierActor = factory.createActor(MessageCollectorActor.props(),
factory.generateActorId(follower1Id + "-notifier"));
followerConfigParams = newFollowerConfigParams();
waitUntilLeader(leaderActor);
expectMatching(leaderCollectorActor, AppendEntriesReply.class, 2);
+ expectFirstMatching(follower1CollectorActor, AppendEntries.class);
clearMessages(leaderCollectorActor);
clearMessages(follower1CollectorActor);
follower1Context = follower1Actor.underlyingActor().getRaftActorContext();
follower2Context = follower2Actor.underlyingActor().getRaftActorContext();
- testLog.info("createRaftActors ending");
+ testLog.info("createRaftActors ending - follower1: {}, follower2: {}", follower1Id, follower2Id);
}
}