1 files changed, 2 insertions, 1 deletions

diff --git a/framework/src/onos/core/store/dist/src/main/java/org/onosproject/store/cluster/messaging/impl/NettyMessagingManager.java b/framework/src/onos/core/store/dist/src/main/java/org/onosproject/store/cluster/messaging/impl/NettyMessagingManager.java
index d61d7dcf..ca6f9c1c 100644
--- a/framework/src/onos/core/store/dist/src/main/java/org/onosproject/store/cluster/messaging/impl/NettyMessagingManager.java
+++ b/framework/src/onos/core/store/dist/src/main/java/org/onosproject/store/cluster/messaging/impl/NettyMessagingManager.java
@@ -48,7 +48,8 @@ public class NettyMessagingManager extends NettyMessaging {
     public void activate() throws Exception {
         ControllerNode localNode = clusterMetadataService.getLocalNode();
         getTlsParameters();
-        super.start(new Endpoint(localNode.ip(), localNode.tcpPort()));
+        super.start(clusterMetadataService.getClusterMetadata().getName().hashCode(),
+                    new Endpoint(localNode.ip(), localNode.tcpPort()));
         log.info("Started");
     }