}
@Test
- public void testOnRegisterCandidateLocal() throws Exception {
+ public void testOnRegisterCandidateLocal() {
testLog.info("testOnRegisterCandidateLocal starting");
ShardTestKit kit = new ShardTestKit(getSystem());
}
@Test
- public void testOnRegisterCandidateLocalWithNoInitialLeader() throws Exception {
+ public void testOnRegisterCandidateLocalWithNoInitialLeader() {
testLog.info("testOnRegisterCandidateLocalWithNoInitialLeader starting");
final ShardTestKit kit = new ShardTestKit(getSystem());
}
@Test
- public void testOnRegisterCandidateLocalWithNoInitialConsensus() throws Exception {
+ public void testOnRegisterCandidateLocalWithNoInitialConsensus() {
testLog.info("testOnRegisterCandidateLocalWithNoInitialConsensus starting");
final ShardTestKit kit = new ShardTestKit(getSystem());
}
@Test
- public void testOnRegisterCandidateLocalWithRemoteLeader() throws Exception {
+ public void testOnRegisterCandidateLocalWithRemoteLeader() {
testLog.info("testOnRegisterCandidateLocalWithRemoteLeader starting");
ShardTestKit kit = new ShardTestKit(getSystem());
}
@Test
- public void testOnUnregisterCandidateLocal() throws Exception {
+ public void testOnUnregisterCandidateLocal() {
testLog.info("testOnUnregisterCandidateLocal starting");
ShardTestKit kit = new ShardTestKit(getSystem());
}
@Test
- public void testOwnershipChanges() throws Exception {
+ public void testOwnershipChanges() {
testLog.info("testOwnershipChanges starting");
final ShardTestKit kit = new ShardTestKit(getSystem());
leaderLastApplied.set(rs.getLastApplied());
});
- verifyRaftState(peer2, rs -> {
- assertEquals("LastApplied", leaderLastApplied.get(), rs.getLastIndex());
- });
+ verifyRaftState(peer2, rs -> assertEquals("LastApplied", leaderLastApplied.get(), rs.getLastIndex()));
// Kill the local leader and elect peer2 the leader. This should cause a new owner to be selected for
// the entities (1 and 3) previously owned by the local leader member.
}
@Test
- public void testListenerRegistration() throws Exception {
+ public void testListenerRegistration() {
testLog.info("testListenerRegistration starting");
ShardTestKit kit = new ShardTestKit(getSystem());
}
@Test
- public void testDelayedEntityOwnerSelectionWhenMaxPeerRequestsReceived() throws Exception {
+ public void testDelayedEntityOwnerSelectionWhenMaxPeerRequestsReceived() {
testLog.info("testDelayedEntityOwnerSelectionWhenMaxPeerRequestsReceived starting");
ShardTestKit kit = new ShardTestKit(getSystem());
}
@Test
- public void testDelayedEntityOwnerSelection() throws Exception {
+ public void testDelayedEntityOwnerSelection() {
testLog.info("testDelayedEntityOwnerSelection starting");
final ShardTestKit kit = new ShardTestKit(getSystem());