From b0a2d2ad809abf214d4f26a3e7b5d78001bba9b3 Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Fri, 25 Dec 2020 22:37:48 +0800
Subject: [PATCH]

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

diff --git a/src/org/redkale/mq/MessageClient.java b/src/org/redkale/mq/MessageClient.java
index ab2e9e940..38e04e995 100644
--- a/src/org/redkale/mq/MessageClient.java
+++ b/src/org/redkale/mq/MessageClient.java
@@ -48,7 +48,7 @@ public abstract class MessageClient {
         return this.respConsumer.shutdown();
     }
 
-    protected CompletableFuture<MessageRecord> sendMessage(MessageRecord message, boolean needresp, AtomicLong counter) {
+    protected CompletableFuture<MessageRecord> sendMessage(final MessageRecord message, boolean needresp, AtomicLong counter) {
         CompletableFuture<MessageRecord> future = new CompletableFuture<>();
         try {
             if (this.respConsumer == null) {
@@ -59,7 +59,7 @@ public abstract class MessageClient {
                             long now = System.currentTimeMillis();
                             MessageRespFutureNode node = respNodes.remove(msg.getSeqid());
                             if (node == null) {
-                                messageAgent.logger.log(Level.WARNING, MessageClient.this.getClass().getSimpleName() + " process " + msg + " error， not found msgnode");
+                                messageAgent.logger.log(Level.WARNING, MessageClient.this.getClass().getSimpleName() + " process " + msg + " error， not found mqmsg.respnode");
                                 return;
                             }
                             AtomicLong ncer = node.getCounter();