From 146b81ee5e8b7d141cfeb432fed6e3b8586dc2c7 Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Fri, 12 Jun 2020 19:21:41 +0800
Subject: [PATCH]

---
 src/org/redkale/mq/MessageAgent.java | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git a/src/org/redkale/mq/MessageAgent.java b/src/org/redkale/mq/MessageAgent.java
index c5c4208f3..d3cd351d7 100644
--- a/src/org/redkale/mq/MessageAgent.java
+++ b/src/org/redkale/mq/MessageAgent.java
@@ -137,8 +137,9 @@ public abstract class MessageAgent {
         if (this.sncpProducer == null) {
             synchronized (sncpProducerLock) {
                 if (this.sncpProducer == null) {
-                    this.sncpProducer = createProducer("SncpProducer");
-                    this.sncpProducer.startup().join();
+                    MessageProducer producer = createProducer("SncpProducer");
+                    producer.startup().join();
+                    this.sncpProducer = producer;
                 }
             }
         }
@@ -149,8 +150,9 @@ public abstract class MessageAgent {
         if (this.httpProducer == null) {
             synchronized (httpProducerLock) {
                 if (this.httpProducer == null) {
-                    this.httpProducer = createProducer("HttpProducer");
-                    this.httpProducer.startup().join();
+                    MessageProducer producer = createProducer("HttpProducer");
+                    producer.startup().join();
+                    this.httpProducer = producer;
                 }
             }
         }