Removed dead code. Took care of some tech debt
diff --git a/core/store/dist/src/main/java/org/onlab/onos/store/service/impl/ClusterMessagingProtocol.java b/core/store/dist/src/main/java/org/onlab/onos/store/service/impl/ClusterMessagingProtocol.java
index e4c9686..f8243c7 100644
--- a/core/store/dist/src/main/java/org/onlab/onos/store/service/impl/ClusterMessagingProtocol.java
+++ b/core/store/dist/src/main/java/org/onlab/onos/store/service/impl/ClusterMessagingProtocol.java
@@ -168,10 +168,10 @@
@Override
public ProtocolClient createClient(TcpMember member) {
- ControllerNode node = getControllerNode(member.host(), member.port());
- checkNotNull(node, "A valid controller node is expected");
+ ControllerNode remoteNode = getControllerNode(member.host(), member.port());
+ checkNotNull(remoteNode, "A valid controller node is expected");
return new ClusterMessagingProtocolClient(
- clusterCommunicator, node);
+ clusterCommunicator, clusterService.getLocalNode(), remoteNode);
}
private ControllerNode getControllerNode(String host, int port) {