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 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();