diff --git a/src/org/redkale/mq/HttpMessageProcessor.java b/src/org/redkale/mq/HttpMessageProcessor.java
index 6ff35043b..3c6a88633 100644
--- a/src/org/redkale/mq/HttpMessageProcessor.java
+++ b/src/org/redkale/mq/HttpMessageProcessor.java
@@ -25,6 +25,8 @@ public class HttpMessageProcessor implements MessageProcessor {
 
     protected final boolean finest;
 
+    protected final boolean finer;
+
     protected final Logger logger;
 
     protected final MessageProducers producer;
@@ -52,6 +54,7 @@ public class HttpMessageProcessor implements MessageProcessor {
     public HttpMessageProcessor(Logger logger, ThreadHashExecutor workExecutor, MessageProducers producer, NodeHttpServer server, Service service, HttpServlet servlet) {
         this.logger = logger;
         this.finest = logger.isLoggable(Level.FINEST);
+        this.finer = logger.isLoggable(Level.FINER);
         this.producer = producer;
         this.server = server;
         this.service = service;
@@ -80,7 +83,12 @@ 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 (mq.delay = " + (System.currentTimeMillis() - message.createtime) + " ms) message: " + message);
+            long cha = System.currentTimeMillis() - message.createtime;
+            if (cha > 50 || finer) {
+                logger.log(Level.FINER, "HttpMessageProcessor.process (mq.delay = " + cha + " ms) message: " + message);
+            } else if (finest) {
+                logger.log(Level.FINEST, "HttpMessageProcessor.process (mq.delay = " + cha + " 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 e16bd9290..79557ff6a 100644
--- a/src/org/redkale/mq/MessageClient.java
+++ b/src/org/redkale/mq/MessageClient.java
@@ -32,9 +32,12 @@ public abstract class MessageClient {
 
     protected boolean finest;
 
+    protected boolean finer;
+
     protected MessageClient(MessageAgent messageAgent) {
         this.messageAgent = messageAgent;
         this.finest = messageAgent == null ? false : messageAgent.logger.isLoggable(Level.FINEST);
+        this.finer = messageAgent == null ? false : messageAgent.logger.isLoggable(Level.FINER);
     }
 
     protected CompletableFuture<Void> close() {
@@ -59,7 +62,12 @@ 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);
+                            long cha = now - msg.createtime;
+                            if (cha > 50 || finer) {
+                                messageAgent.logger.log(Level.FINER, "MessageRespFutureNode.process (mq.delay = " + cha + "ms) message: " + message);
+                            } else if (finest) {
+                                messageAgent.logger.log(Level.FINEST, "MessageRespFutureNode.process (mq.delay = " + cha + "ms) message: " + message);
+                            }
 
                         };
                         MessageConsumer one = messageAgent.createConsumer(new String[]{respTopic}, respConsumerid, processor);