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

---
 src/org/redkale/mq/MessageClient.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/org/redkale/mq/MessageClient.java b/src/org/redkale/mq/MessageClient.java
index 75de3558e..64d613180 100644
--- a/src/org/redkale/mq/MessageClient.java
+++ b/src/org/redkale/mq/MessageClient.java
@@ -66,7 +66,7 @@ public abstract class MessageClient {
                     if (this.respConsumerid == null) this.respConsumerid = "consumer-" + this.respTopic;
                     if (this.consumer == null) {
                         MessageProcessor processor = (msg, callback) -> {
-                            MessageRespFutureNode node = respNodes.get(msg.getSeqid());
+                            MessageRespFutureNode node = respNodes.remove(msg.getSeqid());
                             if (node == null) {
                                 messageAgent.logger.log(Level.WARNING, MessageClient.this.getClass().getSimpleName() + " process " + msg + " error， not found msgnode");
                                 return;