testLog.info("testLeaderTransferOnShutDown ending");
}
- private void sendShutDown(ActorRef actor) throws Exception {
+ private void sendShutDown(final ActorRef actor) throws Exception {
testLog.info("sendShutDown for {} starting", actor.path());
FiniteDuration duration = FiniteDuration.create(5, TimeUnit.SECONDS);
testLog.info("createRaftActors starting");
}
- private static void verifyRaftState(ActorRef raftActor, final RaftState expState) {
+ private static void verifyRaftState(final ActorRef raftActor, final RaftState expState) {
verifyRaftState(raftActor, rs -> assertEquals("getRaftState", expState.toString(), rs.getRaftState()));
}
- private void verifyLeaderStateChangedMessages(TestActorRef<MessageCollectorActor> notifierActor,
- String... expLeaderIds) {
+ private static void verifyLeaderStateChangedMessages(final TestActorRef<MessageCollectorActor> notifierActor,
+ final String... expLeaderIds) {
List<LeaderStateChanged> leaderStateChanges = expectMatching(notifierActor, LeaderStateChanged.class,
expLeaderIds.length);
if (message instanceof RequestEnvelope) {
handleRequestEnvelope((RequestEnvelope)message);
- } else if (requestMessageAssembler.isHandledMessage(message)) {
+ } else if (MessageAssembler.isHandledMessage(message)) {
handleRequestAssemblerMessage(message);
} else if (message instanceof ConnectClientRequest) {
handleConnectClient((ConnectClientRequest)message);
}
}
- private void handleRequestAssemblerMessage(Object message) {
+ private void handleRequestAssemblerMessage(final Object message) {
dispatchers.getDispatcher(DispatcherType.Serialization).execute(() -> {
JavaSerializer.currentSystem().value_$eq((ExtendedActorSystem) context().system());
requestMessageAssembler.handleMessage(message, self());