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();