import akka.actor.Props;
import akka.actor.Terminated;
import akka.japi.Procedure;
-import akka.persistence.RecoveryCompleted;
import akka.persistence.SaveSnapshotFailure;
import akka.persistence.SaveSnapshotSuccess;
import akka.persistence.SnapshotMetadata;
MockRaftActor leaderActor = mockActorRef.underlyingActor();
- leaderActor.handleRecover(RecoveryCompleted.getInstance());
+ leaderActor.waitForRecoveryComplete();
leaderActor.handleCommand(new SwitchBehavior(RaftState.Follower, 100));