diff --git a/src/org/redkale/mq/MessageConsumer.java b/src/org/redkale/mq/MessageConsumer.java
index de2bc6da0..1e15b33a8 100644
--- a/src/org/redkale/mq/MessageConsumer.java
+++ b/src/org/redkale/mq/MessageConsumer.java
@@ -50,9 +50,9 @@ public abstract class MessageConsumer {
 
     public abstract CompletableFuture<Void> startup();
 
-    protected boolean isClosed() {
+    public boolean isClosed() {
         return closed;
     }
 
-    protected abstract CompletableFuture<Void> shutdown();
+    public abstract CompletableFuture<Void> shutdown();
 }
diff --git a/src/org/redkale/mq/MessageProducer.java b/src/org/redkale/mq/MessageProducer.java
index 95e7ec00f..27462cd67 100644
--- a/src/org/redkale/mq/MessageProducer.java
+++ b/src/org/redkale/mq/MessageProducer.java
@@ -27,9 +27,9 @@ public abstract class MessageProducer  {
 
     public abstract CompletableFuture<Void> startup();
 
-    protected boolean isClosed() {
+    public boolean isClosed() {
         return closed;
     }
 
-    protected abstract CompletableFuture<Void> shutdown();
+    public abstract CompletableFuture<Void> shutdown();
 }