From f83fc52e9cd046a6585eef617c512ef004add088 Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Sun, 31 May 2020 11:59:11 +0800
Subject: [PATCH]

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

diff --git a/src/org/redkale/mq/MessageAgent.java b/src/org/redkale/mq/MessageAgent.java
index 49dd91735..a1dca973a 100644
--- 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();
+    }
 }