From 7e777229bad3d5c550c7ec4d2e78ec432af075bb Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Tue, 15 Dec 2020 21:55:32 +0800
Subject: [PATCH]

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

diff --git a/src/org/redkale/mq/HttpMessageProcessor.java b/src/org/redkale/mq/HttpMessageProcessor.java
index 3c6a88633..1b9656be1 100644
--- a/src/org/redkale/mq/HttpMessageProcessor.java
+++ b/src/org/redkale/mq/HttpMessageProcessor.java
@@ -85,7 +85,7 @@ public class HttpMessageProcessor implements MessageProcessor {
         try {
             long cha = System.currentTimeMillis() - message.createtime;
             if (cha > 50 || finer) {
-                logger.log(Level.FINER, "HttpMessageProcessor.process (mq.delay = " + cha + " ms) message: " + message);
+                logger.log(Level.FINER, "HttpMessageProcessor.process (mq.delays = " + cha + " ms) message: " + message);
             } else if (finest) {
                 logger.log(Level.FINEST, "HttpMessageProcessor.process (mq.delay = " + cha + " ms) message: " + message);
             }
diff --git a/src/org/redkale/mq/MessageClient.java b/src/org/redkale/mq/MessageClient.java
index 3d8d5f762..1d76c6c8f 100644
--- a/src/org/redkale/mq/MessageClient.java
+++ b/src/org/redkale/mq/MessageClient.java
@@ -64,7 +64,7 @@ public abstract class MessageClient {
                             node.future.complete(msg);
                             long cha = now - msg.createtime;
                             if (cha > 50 || finer) {
-                                messageAgent.logger.log(Level.FINER, "MessageRespFutureNode.process (mq.delay = " + cha + "ms) message: " + msg);
+                                messageAgent.logger.log(Level.FINER, "MessageRespFutureNode.process (mq.delays = " + cha + "ms) message: " + msg);
                             } else if (finest) {
                                 messageAgent.logger.log(Level.FINEST, "MessageRespFutureNode.process (mq.delay = " + cha + "ms) message: " + msg);
                             }