commit | 3b016734c37598a2338cceb270b9e9bff67d0d8a | [log] [tgz] |
---|---|---|
author | Yuta HIGUCHI <y-higuchi@onlab.us> | Fri Nov 07 15:32:18 2014 -0800 |
committer | Yuta HIGUCHI <y-higuchi@onlab.us> | Fri Nov 07 17:07:32 2014 -0800 |
tree | 55391160a8f967d63f2b9e2caf17dc288bccdb6c | |
parent | 535c915f0b601143218d79e9a3badfbd9808557f [diff] |
ClusterMessagingProtocolClient: cosmetics Change-Id: I1bcdf1a11f3f779a326b29fdea94645c4ff3ea7b
diff --git a/core/store/dist/src/main/java/org/onlab/onos/store/service/impl/ClusterMessagingProtocolClient.java b/core/store/dist/src/main/java/org/onlab/onos/store/service/impl/ClusterMessagingProtocolClient.java index be0da20..855d58c 100644 --- a/core/store/dist/src/main/java/org/onlab/onos/store/service/impl/ClusterMessagingProtocolClient.java +++ b/core/store/dist/src/main/java/org/onlab/onos/store/service/impl/ClusterMessagingProtocolClient.java
@@ -85,7 +85,7 @@ return CompletableFuture.completedFuture(null); } - public <I> MessageSubject messageType(I input) { + private <I> MessageSubject messageType(I input) { Class<?> clazz = input.getClass(); if (clazz.equals(PollRequest.class)) { return ClusterMessagingProtocol.COPYCAT_POLL; @@ -117,7 +117,7 @@ this.request = request; this.message = new ClusterMessage( - null, + null, // FIXME fill in proper sender messageType(request), ClusterMessagingProtocol.SERIALIZER.encode(request)); this.future = future;