From c2e3636062ade8cb227879e15405e74a53499a03 Mon Sep 17 00:00:00 2001
From: redkale <redkale@qq.com>
Date: Sat, 14 Oct 2023 10:04:40 +0800
Subject: [PATCH] =?UTF-8?q?=E6=97=A5=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../org/redkale/mq/MessageRespProcessor.java     | 16 ++++++++--------
 src/main/java/org/redkale/mq/MessageServlet.java |  2 +-
 2 files changed, 9 insertions(+), 9 deletions(-)

diff --git a/src/main/java/org/redkale/mq/MessageRespProcessor.java b/src/main/java/org/redkale/mq/MessageRespProcessor.java
index 60d0b19f5..abe981cd1 100644
--- a/src/main/java/org/redkale/mq/MessageRespProcessor.java
+++ b/src/main/java/org/redkale/mq/MessageRespProcessor.java
@@ -37,19 +37,19 @@ public class MessageRespProcessor implements MessageProcessor {
         if (resp.scheduledFuture != null) {
             resp.scheduledFuture.cancel(true);
         }
-        final long cha = now - msg.createTime;
+        final long deplay = now - msg.createTime;
         if (finest) {
-            logger.log(Level.FINEST, getClass().getSimpleName() + ".MessageRespFuture.receive (mq.delay = " + cha + "ms, mq.seqid = " + msg.getSeqid() + ")");
+            logger.log(Level.FINEST, getClass().getSimpleName() + ".MessageRespFuture.receive (mq.delay = " + deplay + "ms, mq.seqid = " + msg.getSeqid() + ")");
         }
         messageClient.getMessageAgent().execute(() -> {
             resp.future.complete(msg);
-            long cha2 = System.currentTimeMillis() - now;
-            if ((cha > 1000 || cha2 > 1000) && logger.isLoggable(Level.FINE)) {
-                logger.log(Level.FINE, getClass().getSimpleName() + ".MessageRespFuture.complete (mqs.delays = " + cha + "ms, mqs.completes = " + cha2 + "ms) mqresp.msg: " + msg);
-            } else if ((cha > 50 || cha2 > 50) && logger.isLoggable(Level.FINER)) {
-                logger.log(Level.FINER, getClass().getSimpleName() + ".MessageRespFuture.complete (mq.delays = " + cha + "ms, mq.completes = " + cha2 + "ms) mqresp.msg: " + msg);
+            long comems = System.currentTimeMillis() - now;
+            if ((deplay > 1000 || comems > 1000) && logger.isLoggable(Level.FINE)) {
+                logger.log(Level.FINE, getClass().getSimpleName() + ".MessageRespFuture.complete (mq.delay-slower = " + deplay + "ms, mq.complete-slower = " + comems + "ms) mqresp.msg: " + msg);
+            } else if ((deplay > 50 || comems > 50) && logger.isLoggable(Level.FINER)) {
+                logger.log(Level.FINER, getClass().getSimpleName() + ".MessageRespFuture.complete (mq.delay-slowly = " + deplay + "ms, mq.complete-slowly = " + comems + "ms) mqresp.msg: " + msg);
             } else if (finest) {
-                logger.log(Level.FINEST, getClass().getSimpleName() + ".MessageRespFuture.complete (mq.delay = " + cha + "ms, mq.complete = " + cha2 + "ms) mqresp.msg: " + msg);
+                logger.log(Level.FINEST, getClass().getSimpleName() + ".MessageRespFuture.complete (mq.delay-normal = " + deplay + "ms, mq.complete-normal = " + comems + "ms) mqresp.msg: " + msg);
             }
         });
     }
diff --git a/src/main/java/org/redkale/mq/MessageServlet.java b/src/main/java/org/redkale/mq/MessageServlet.java
index 54b27b7db..d2f31f8cb 100644
--- a/src/main/java/org/redkale/mq/MessageServlet.java
+++ b/src/main/java/org/redkale/mq/MessageServlet.java
@@ -61,7 +61,7 @@ public abstract class MessageServlet implements MessageProcessor {
             context.execute(servlet, request, response);
             long exems = System.currentTimeMillis() - now;
             if ((delay > 1000 || block > 100 || exems > 1000) && logger.isLoggable(Level.FINE)) {
-                logger.log(Level.FINE, getClass().getSimpleName() + ".process (mqs.delay-slower = " + delay + " ms, mqs.block = " + block + " ms, mqs.executes = " + exems + " ms) message: " + message);
+                logger.log(Level.FINE, getClass().getSimpleName() + ".process (mq.delay-slower = " + delay + " ms, mq.block = " + block + " ms, mq.executes = " + exems + " ms) message: " + message);
             } else if ((delay > 50 || block > 10 || exems > 50) && logger.isLoggable(Level.FINER)) {
                 logger.log(Level.FINER, getClass().getSimpleName() + ".process (mq.delay-slowly = " + delay + " ms, mq.block = " + block + " ms, mq.executes = " + exems + " ms) message: " + message);
             } else if (logger.isLoggable(Level.FINEST)) {