From 0377dac71fcfa9736964a0ec6e1446fef2a618e7 Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Sun, 14 Jun 2020 01:01:38 +0800
Subject: [PATCH]

---
 src/org/redkale/mq/MessageClient.java | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git a/src/org/redkale/mq/MessageClient.java b/src/org/redkale/mq/MessageClient.java
index d1df298f3..8ea3095a6 100644
--- a/src/org/redkale/mq/MessageClient.java
+++ b/src/org/redkale/mq/MessageClient.java
@@ -65,17 +65,18 @@ public abstract class MessageClient {
                 synchronized (this) {
                     if (this.respConsumerid == null) this.respConsumerid = "consumer-" + this.respTopic;
                     if (this.consumer == null) {
-                        MessageProcessor processor = (msg,callback) -> {
+                        MessageProcessor processor = (msg, callback) -> {
                             MessageRespFutureNode node = respNodes.get(msg.getSeqid());
                             if (node == null) {
-                                messageAgent.logger.log(Level.WARNING, MessageClient.this.getClass().getSimpleName() + " process " + msg + " error");
+                                messageAgent.logger.log(Level.WARNING, MessageClient.this.getClass().getSimpleName() + " process " + msg + " error， not found msgnode");
                                 return;
                             }
                             if (node.getCounter() != null) node.getCounter().decrementAndGet();
                             node.future.complete(msg);
                         };
-                        this.consumer = messageAgent.createConsumer(new String[]{respTopic}, respConsumerid, processor);
-                        this.consumer.startup().join();
+                        MessageConsumer one = messageAgent.createConsumer(new String[]{respTopic}, respConsumerid, processor);
+                        one.startup().join();
+                        this.consumer = one;
                     }
                 }
             }