diff --git a/src/org/redkale/mq/MessageAgent.java b/src/org/redkale/mq/MessageAgent.java index 75b5622f1..dfa3c25e5 100644 --- a/src/org/redkale/mq/MessageAgent.java +++ b/src/org/redkale/mq/MessageAgent.java @@ -180,17 +180,17 @@ public abstract class MessageAgent { return "http.req." + module.toLowerCase(); } + //格式: http.resp.node10 + public String generateHttpRespTopic() { + return "http.resp.node" + nodeid; + } + //格式: http.req.user protected String generateHttpReqTopic(Service service) { String resname = Sncp.getResourceName(service); return "http.req." + Rest.getRestName(service).toLowerCase() + (resname.isEmpty() ? "" : ("-" + resname)); } - //格式: http.resp.node10 - protected String generateHttpRespTopic() { - return "http.resp.node" + nodeid; - } - //格式: ws.resp.wsgame public String generateWebSocketRespTopic(WebSocketNode node) { return "ws.resp." + node.getName();