LeaderElectionService { public void leaderForceElection() { jobNodeStorage.executeInLeader(ElectionNode.LATCH, new LeaderElectionExecutionCallback(true)); } LeaderElectionService(final CoordinatorRegistryCenter coordinatorRegistryCenter, final JobConfiguration jobConfiguration); void leaderForceElection(); void leaderElection(); Boolean isLeader(); boolean hasLeader(); void removeLeader();  }
@Test public void assertLeaderForceElection() { leaderElectionService.leaderForceElection(); verify(jobNodeStorage).executeInLeader(eq("leader/election/latch"), Matchers.<LeaderElectionExecutionCallback>any()); }