diff --git a/src/org/redkale/mq/MessageAgent.java b/src/org/redkale/mq/MessageAgent.java
index 98af61cd6..95718bdef 100644
--- a/src/org/redkale/mq/MessageAgent.java
+++ b/src/org/redkale/mq/MessageAgent.java
@@ -92,7 +92,7 @@ public abstract class MessageAgent {
     public abstract MessageConsumer createConsumer(String topic, Consumer<MessageRecord> processor);
 
     //格式: sncp:req:user
-    protected static String generateSncpReqTopic(NodeServer ns, Service service) {
+    protected static String generateSncpReqTopic(Service service) {
         String resname = Sncp.getResourceName(service);
         return "sncp:req:" + Sncp.getResourceType(service).getSimpleName().replaceAll("Service.*$", "").toLowerCase() + (resname.isEmpty() ? "" : ("-" + resname));
     }
@@ -103,7 +103,7 @@ public abstract class MessageAgent {
     }
 
     //格式: http:req:user
-    protected static String generateHttpReqTopic(NodeServer ns, Service service) {
+    protected static String generateHttpReqTopic(Service service) {
         String resname = Sncp.getResourceName(service);
         return "http:req:" + Rest.getWebModuleName(service.getClass()).toLowerCase() + (resname.isEmpty() ? "" : ("-" + resname));
     }
diff --git a/src/org/redkale/mq/MessageConsumer.java b/src/org/redkale/mq/MessageConsumer.java
index 6b49d2cd2..bf4b19f75 100644
--- a/src/org/redkale/mq/MessageConsumer.java
+++ b/src/org/redkale/mq/MessageConsumer.java
@@ -43,9 +43,9 @@ public abstract class MessageConsumer extends Thread {
 
     public abstract void waitFor();
 
-    public boolean isClosed() {
+    protected boolean isClosed() {
         return closed;
     }
 
-    public abstract void close();
+    protected abstract void close();
 }
diff --git a/src/org/redkale/mq/MessageProducer.java b/src/org/redkale/mq/MessageProducer.java
index 7b66bdff8..8d6e6ef6b 100644
--- a/src/org/redkale/mq/MessageProducer.java
+++ b/src/org/redkale/mq/MessageProducer.java
@@ -23,11 +23,11 @@ public abstract class MessageProducer extends Thread {
 
     public abstract CompletableFuture apply(MessageRecord message);
 
-    public abstract void waitFor();
+    protected abstract void waitFor();
 
-    public boolean isClosed() {
+    protected boolean isClosed() {
         return closed;
     }
 
-    public abstract void close();
+    protected abstract void close();
 }