2020-05-31 11:59:11 +08:00
parent 2f8a04c15d
commit f83fc52e9c
1 changed files with 4 additions and 0 deletions
--- a/src/org/redkale/mq/MessageAgent.java
+++ b/src/org/redkale/mq/MessageAgent.java
@@ -120,4 +120,8 @@ public abstract class MessageAgent {
        return "ws:resp:node" + application.getNodeid();
    }

+    //格式: xxxx:resp:node10
+    protected static String generateRespTopic(String protocol, Application application) {
+        return protocol + ":resp:node" + application.getNodeid();
+    }
 }