diff --git a/src/org/redkale/mq/HttpMessageProcessor.java b/src/org/redkale/mq/HttpMessageProcessor.java index c1ef3f8ac..6ff35043b 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(mq.delay=" + (System.currentTimeMillis() - message.createtime) + "ms) 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 bd383e864..e16bd9290 100644 --- a/src/org/redkale/mq/MessageClient.java +++ b/src/org/redkale/mq/MessageClient.java @@ -59,7 +59,7 @@ 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); + 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);