Yuta HIGUCHI

ClusterMessagingProtocolClient: cosmetics

Change-Id: I1bcdf1a11f3f779a326b29fdea94645c4ff3ea7b
...@@ -85,7 +85,7 @@ public class ClusterMessagingProtocolClient implements ProtocolClient { ...@@ -85,7 +85,7 @@ public class ClusterMessagingProtocolClient implements ProtocolClient {
85 return CompletableFuture.completedFuture(null); 85 return CompletableFuture.completedFuture(null);
86 } 86 }
87 87
88 - public <I> MessageSubject messageType(I input) { 88 + private <I> MessageSubject messageType(I input) {
89 Class<?> clazz = input.getClass(); 89 Class<?> clazz = input.getClass();
90 if (clazz.equals(PollRequest.class)) { 90 if (clazz.equals(PollRequest.class)) {
91 return ClusterMessagingProtocol.COPYCAT_POLL; 91 return ClusterMessagingProtocol.COPYCAT_POLL;
...@@ -117,7 +117,7 @@ public class ClusterMessagingProtocolClient implements ProtocolClient { ...@@ -117,7 +117,7 @@ public class ClusterMessagingProtocolClient implements ProtocolClient {
117 this.request = request; 117 this.request = request;
118 this.message = 118 this.message =
119 new ClusterMessage( 119 new ClusterMessage(
120 - null, 120 + null, // FIXME fill in proper sender
121 messageType(request), 121 messageType(request),
122 ClusterMessagingProtocol.SERIALIZER.encode(request)); 122 ClusterMessagingProtocol.SERIALIZER.encode(request));
123 this.future = future; 123 this.future = future;
......