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