From 851c81e096f3c92162ff6fce87f08748fab308e6 Mon Sep 17 00:00:00 2001
From: redkale <redkale@qq.com>
Date: Wed, 1 Feb 2023 19:53:55 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96MessageProducer=E7=9A=84close?=
 =?UTF-8?q?d?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/org/redkale/mq/MessageProducer.java | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/src/main/java/org/redkale/mq/MessageProducer.java b/src/main/java/org/redkale/mq/MessageProducer.java
index dcbabecc6..2a990c5a3 100644
--- a/src/main/java/org/redkale/mq/MessageProducer.java
+++ b/src/main/java/org/redkale/mq/MessageProducer.java
@@ -6,6 +6,7 @@
 package org.redkale.mq;
 
 import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.logging.Logger;
 
 /**
@@ -23,7 +24,7 @@ public abstract class MessageProducer {
 
     protected final String name;
 
-    protected volatile boolean closed;
+    protected final AtomicBoolean closed = new AtomicBoolean();
 
     protected MessageProducer(String name, Logger logger) {
         this.name = name;
@@ -35,7 +36,7 @@ public abstract class MessageProducer {
     public abstract CompletableFuture<Void> startup();
 
     public boolean isClosed() {
-        return closed;
+        return closed.get();
     }
 
     public abstract CompletableFuture<Void> shutdown();