From 4f32dcda16a54d4a19eebb7861bb3e76f6ef0c28 Mon Sep 17 00:00:00 2001 From: Redkale <8730487+redkale@users.noreply.github.com> Date: Sun, 10 Jan 2021 10:33:48 +0800 Subject: [PATCH] --- src/org/redkale/mq/MessageClient.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/org/redkale/mq/MessageClient.java b/src/org/redkale/mq/MessageClient.java index c2a34a092..666233e29 100644 --- a/src/org/redkale/mq/MessageClient.java +++ b/src/org/redkale/mq/MessageClient.java @@ -72,11 +72,11 @@ public abstract class MessageClient { node.future.complete(msg); long cha = now - msg.createtime; if (cha > 1000 && fine) { - messageAgent.logger.log(Level.FINE, "MessageRespFutureNode.process (mqs.delays = " + cha + "ms) mqresp.msg: " + msg); + messageAgent.logger.log(Level.FINE, "MessageRespFutureNode.process (mqs.delays = " + cha + "ms, mqs.counter = " + (ncer == null ? -1 : ncer.get()) + ") mqresp.msg: " + msg); } else if (cha > 50 && finer) { - messageAgent.logger.log(Level.FINER, "MessageRespFutureNode.process (mq.delays = " + cha + "ms) mqresp.msg: " + msg); + messageAgent.logger.log(Level.FINER, "MessageRespFutureNode.process (mq.delays = " + cha + "ms, mqs.counter = " + (ncer == null ? -1 : ncer.get()) + ") mqresp.msg: " + msg); } else if (finest) { - messageAgent.logger.log(Level.FINEST, "MessageRespFutureNode.process (mq.delay = " + cha + "ms) mqresp.msg: " + msg); + messageAgent.logger.log(Level.FINEST, "MessageRespFutureNode.process (mq.delay = " + cha + "ms, mqs.counter = " + (ncer == null ? -1 : ncer.get()) + ") mqresp.msg: " + msg); } };