From 2f6eb0908e017fa7d754c70d6627e8b9e361ee6c Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Wed, 11 Nov 2020 18:00:37 +0800
Subject: [PATCH]

---
 src/org/redkale/mq/HttpMessageProcessor.java | 2 +-
 src/org/redkale/mq/MessageClient.java        | 6 ++++++
 2 files changed, 7 insertions(+), 1 deletion(-)

diff --git a/src/org/redkale/mq/HttpMessageProcessor.java b/src/org/redkale/mq/HttpMessageProcessor.java
index 4d82fa6d2..c1ef3f8ac 100644
--- a/src/org/redkale/mq/HttpMessageProcessor.java
+++ b/src/org/redkale/mq/HttpMessageProcessor.java
@@ -80,7 +80,7 @@ public class HttpMessageProcessor implements MessageProcessor {
     private void execute(final MessageRecord message, final Runnable callback) {
         HttpMessageRequest request = null;
         try {
-            if (finest) logger.log(Level.FINEST, "HttpMessageProcessor.process message: " + message);
+            if (finest) logger.log(Level.FINEST, "HttpMessageProcessor.process(mq.delay=" + (System.currentTimeMillis() - message.createtime) + "ms) message: " + message);
             if (multiconsumer) message.setResptopic(null); //不容许有响应
             HttpContext context = server.getHttpServer().getContext();
             request = new HttpMessageRequest(context, message);
diff --git a/src/org/redkale/mq/MessageClient.java b/src/org/redkale/mq/MessageClient.java
index 34c1253d9..bd383e864 100644
--- a/src/org/redkale/mq/MessageClient.java
+++ b/src/org/redkale/mq/MessageClient.java
@@ -30,8 +30,11 @@ public abstract class MessageClient {
 
     protected String respConsumerid;
 
+    protected boolean finest;
+
     protected MessageClient(MessageAgent messageAgent) {
         this.messageAgent = messageAgent;
+        this.finest = messageAgent == null ? false : messageAgent.logger.isLoggable(Level.FINEST);
     }
 
     protected CompletableFuture<Void> close() {
@@ -47,6 +50,7 @@ public abstract class MessageClient {
                     if (this.respConsumerid == null) this.respConsumerid = "consumer-" + this.respTopic;
                     if (this.respConsumer == null) {
                         MessageProcessor processor = (msg, callback) -> {
+                            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");
@@ -55,6 +59,8 @@ public abstract class MessageClient {
                             AtomicLong ncer = node.getCounter();
                             if (ncer != null) ncer.decrementAndGet();
                             node.future.complete(msg);
+                            if (finest) messageAgent.logger.log(Level.FINEST, "MessageRespFutureNode.process(mq.delay=" + (now - msg.createtime) + "ms) message: " + message);
+
                         };
                         MessageConsumer one = messageAgent.createConsumer(new String[]{respTopic}, respConsumerid, processor);
                         one.startup().join();