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;