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

---
 src/org/redkale/mq/MessageClient.java         | 2 +-
 src/org/redkale/mq/MessageRespFutureNode.java | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/org/redkale/mq/MessageClient.java b/src/org/redkale/mq/MessageClient.java
index 64d613180..4ffbf3382 100644
--- a/src/org/redkale/mq/MessageClient.java
+++ b/src/org/redkale/mq/MessageClient.java
@@ -87,7 +87,7 @@ public abstract class MessageClient {
             if (counter != null) counter.incrementAndGet();
             getProducer().apply(message);
             if (needresp) {
-                MessageRespFutureNode node = new MessageRespFutureNode(message.getSeqid(),message, respNodes, counter, future);
+                MessageRespFutureNode node = new MessageRespFutureNode(message, respNodes, counter, future);
                 respNodes.put(message.getSeqid(), node);
                 ScheduledThreadPoolExecutor executor = messageAgent.timeoutExecutor;
                 if (executor != null) executor.schedule(node, 6, TimeUnit.SECONDS);
diff --git a/src/org/redkale/mq/MessageRespFutureNode.java b/src/org/redkale/mq/MessageRespFutureNode.java
index 185f2986d..08cbebd6d 100644
--- a/src/org/redkale/mq/MessageRespFutureNode.java
+++ b/src/org/redkale/mq/MessageRespFutureNode.java
@@ -30,8 +30,8 @@ public class MessageRespFutureNode implements Runnable {
 
     protected final ConcurrentHashMap<Long, MessageRespFutureNode> respNodes;
 
-    public MessageRespFutureNode(long seqid, ConcurrentHashMap<Long, MessageRespFutureNode> respNodes, AtomicLong counter, CompletableFuture<MessageRecord> future) {
-        this.seqid = seqid;
+    public MessageRespFutureNode(MessageRecord message, ConcurrentHashMap<Long, MessageRespFutureNode> respNodes, AtomicLong counter, CompletableFuture<MessageRecord> future) {
+        this.seqid = message.getSeqid();
         this.respNodes = respNodes;
         this.counter = counter;
         this.future = future;