From 1d7a72f9929a326e6fc5334b72f74cf9625e4da0 Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Thu, 4 Jun 2020 09:39:38 +0800
Subject: [PATCH]

---
 src/org/redkale/mq/MessageConsumer.java | 4 ++--
 src/org/redkale/mq/MessageProducer.java | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

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