import static org.mockito.Mockito.verify;
import akka.dispatch.Dispatchers;
-import com.google.common.base.Function;
+import java.util.function.Function;
import org.junit.After;
import org.junit.Test;
import org.opendaylight.controller.cluster.raft.RaftActorLeadershipTransferCohort.OnComplete;
factory.close();
}
- private void setup(String testName) {
+ private void setup(final String testName) {
String persistenceId = factory.generateActorId(testName + "-leader-");
config.setCustomRaftPolicyImplementationClass(DisableElectionsRaftPolicy.class.getName());
mockRaftActor = factory.<MockRaftActor>createTestActor(MockRaftActor.builder().id(persistenceId).config(config)
Leader leader = new Leader(mockRaftActor.getRaftActorContext()) {
@Override
- public void transferLeadership(RaftActorLeadershipTransferCohort leadershipTransferCohort) {
+ public void transferLeadership(final RaftActorLeadershipTransferCohort leadershipTransferCohort) {
leadershipTransferCohort.transferComplete();
}
};