Yuta HIGUCHI

ClusterMessagingProtocolServer: cosmetics

Change-Id: Ia44acfa8971196f4c06472d73890cf4fe5722bb6
...@@ -86,13 +86,17 @@ public class ClusterMessagingProtocolServer implements ProtocolServer { ...@@ -86,13 +86,17 @@ public class ClusterMessagingProtocolServer implements ProtocolServer {
86 } 86 }
87 } 87 }
88 if (request.getClass().equals(PingRequest.class)) { 88 if (request.getClass().equals(PingRequest.class)) {
89 - handler.ping((PingRequest) request).whenComplete(new PostExecutionTask<PingResponse>(message)); 89 + handler.ping((PingRequest) request)
90 + .whenComplete(new PostExecutionTask<PingResponse>(message));
90 } else if (request.getClass().equals(PollRequest.class)) { 91 } else if (request.getClass().equals(PollRequest.class)) {
91 - handler.poll((PollRequest) request).whenComplete(new PostExecutionTask<PollResponse>(message)); 92 + handler.poll((PollRequest) request)
93 + .whenComplete(new PostExecutionTask<PollResponse>(message));
92 } else if (request.getClass().equals(SyncRequest.class)) { 94 } else if (request.getClass().equals(SyncRequest.class)) {
93 - handler.sync((SyncRequest) request).whenComplete(new PostExecutionTask<SyncResponse>(message)); 95 + handler.sync((SyncRequest) request)
96 + .whenComplete(new PostExecutionTask<SyncResponse>(message));
94 } else if (request.getClass().equals(SubmitRequest.class)) { 97 } else if (request.getClass().equals(SubmitRequest.class)) {
95 - handler.submit((SubmitRequest) request).whenComplete(new PostExecutionTask<SubmitResponse>(message)); 98 + handler.submit((SubmitRequest) request)
99 + .whenComplete(new PostExecutionTask<SubmitResponse>(message));
96 } else { 100 } else {
97 throw new IllegalStateException("Unknown request type: " + request.getClass().getName()); 101 throw new IllegalStateException("Unknown request type: " + request.getClass().getName());
98 } 102 }
......