From f11870d6bcc2ac999d9b2c4248819fc74695ef34 Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Wed, 3 Jun 2020 20:06:48 +0800
Subject: [PATCH]

---
 src/org/redkale/mq/MessageAgent.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/org/redkale/mq/MessageAgent.java b/src/org/redkale/mq/MessageAgent.java
index c031780d6..75b5622f1 100644
--- a/src/org/redkale/mq/MessageAgent.java
+++ b/src/org/redkale/mq/MessageAgent.java
@@ -164,7 +164,7 @@ public abstract class MessageAgent {
     }
 
     //格式: sncp.req.user
-    protected String generateSncpReqTopic(Service service) {
+    public String generateSncpReqTopic(Service service) {
         String resname = Sncp.getResourceName(service);
         if (service instanceof WebSocketNode) return "sncp.req.wsn" + (resname.isEmpty() ? "" : ("-" + resname));
         return "sncp.req." + Sncp.getResourceType(service).getSimpleName().replaceAll("Service.*$", "").toLowerCase() + (resname.isEmpty() ? "" : ("-" + resname));