From b6d5fc02dce3722c2388f21aa68c5667bdb6ac7b Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Thu, 4 Jun 2020 10:11:14 +0800
Subject: [PATCH]

---
 src/org/redkale/mq/MessageAgent.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/org/redkale/mq/MessageAgent.java b/src/org/redkale/mq/MessageAgent.java
index 76efa73b2..f4d42e833 100644
--- a/src/org/redkale/mq/MessageAgent.java
+++ b/src/org/redkale/mq/MessageAgent.java
@@ -190,9 +190,9 @@ public abstract class MessageAgent {
         return "http.req." + Rest.getRestName(service).toLowerCase() + (resname.isEmpty() ? "" : ("-" + resname));
     }
 
-    //格式: ws.resp.wsgame
+    //格式: ws.resp.wsgame.node100
     public String generateWebSocketRespTopic(WebSocketNode node) {
-        return "ws.resp." + node.getName();
+        return "ws.resp." + node.getName() + ".node" + nodeid;
     }
 
     //格式: xxxx.resp.node10