lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
Redkale
2020-06-04 10:11:14 +08:00
parent 59d139ace2
commit b6d5fc02dc
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/org/redkale/mq/MessageAgent.java
View File

@@ -190,9 +190,9 @@ public abstract class MessageAgent {
return "http.req." + Rest.getRestName(service).toLowerCase() + (resname.isEmpty() ? "" : ("-" + resname)); return "http.req." + Rest.getRestName(service).toLowerCase() + (resname.isEmpty() ? "" : ("-" + resname));
} }
//格式: ws.resp.wsgame //格式: ws.resp.wsgame.node100
public String generateWebSocketRespTopic(WebSocketNode node) { public String generateWebSocketRespTopic(WebSocketNode node) {
return "ws.resp." + node.getName(); return "ws.resp." + node.getName() + ".node" + nodeid;
} }
//格式: xxxx.resp.node10 //格式: xxxx.resp.node10