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