commit | 871009392c53b15e9271e3f9908fafbc0496633c | [log] [tgz] |
---|---|---|
author | Madan Jampani <madan@onlab.us> | Tue Oct 21 16:46:12 2014 -0700 |
committer | Madan Jampani <madan@onlab.us> | Tue Oct 21 16:46:12 2014 -0700 |
tree | 6969ce7f1ecfb6b58bb0976451c20ddf8cbd7fbf | |
parent | 61d59dac06104fb82218d53751cd93e063087931 [diff] [blame] |
Added NettyMessagingService constructor that accepts both ip and port
diff --git a/core/store/dist/src/main/java/org/onlab/onos/store/cluster/messaging/impl/ClusterCommunicationManager.java b/core/store/dist/src/main/java/org/onlab/onos/store/cluster/messaging/impl/ClusterCommunicationManager.java index 55d8b1a..42d89de 100644 --- a/core/store/dist/src/main/java/org/onlab/onos/store/cluster/messaging/impl/ClusterCommunicationManager.java +++ b/core/store/dist/src/main/java/org/onlab/onos/store/cluster/messaging/impl/ClusterCommunicationManager.java
@@ -67,7 +67,7 @@ @Activate public void activate() { ControllerNode localNode = clusterService.getLocalNode(); - NettyMessagingService netty = new NettyMessagingService(localNode.tcpPort()); + NettyMessagingService netty = new NettyMessagingService(localNode.ip().toString(), localNode.tcpPort()); // FIXME: workaround until it becomes a service. try { netty.activate();