RaftActorLeadershipTransferCohort { public void abortTransfer() { LOG.debug("{}: leader transfer aborted", raftActor.persistenceId()); finish(false); } RaftActorLeadershipTransferCohort(final RaftActor raftActor);   RaftActorLeadershipTransferCohort(final RaftActor raftActor, final @Nullable String requestedFollowerId); void abortTransfer(); void transferComplete(); Optional<String> getRequestedFollowerId();  }
@Test public void testAbortTransfer() { setup("testAbortTransfer"); cohort.abortTransfer(); verify(onComplete).onFailure(mockRaftActor.self()); }