From 67717e73ad5318e06788477e56d449fae4472255 Mon Sep 17 00:00:00 2001 From: Redkale <8730487+redkale@users.noreply.github.com> Date: Sun, 10 Jan 2021 10:19:05 +0800 Subject: [PATCH] --- src/org/redkale/mq/MessageRespFutureNode.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/org/redkale/mq/MessageRespFutureNode.java b/src/org/redkale/mq/MessageRespFutureNode.java index 970e91d56..332ad1537 100644 --- a/src/org/redkale/mq/MessageRespFutureNode.java +++ b/src/org/redkale/mq/MessageRespFutureNode.java @@ -51,7 +51,8 @@ public class MessageRespFutureNode implements Runnable { public void run() { //timeout respNodes.remove(this.seqid); future.completeExceptionally(new TimeoutException()); - logger.log(Level.WARNING, getClass().getSimpleName() + " wait msg: " + message + " timeout " + (System.currentTimeMillis() - createtime) + "ms"); + logger.log(Level.WARNING, getClass().getSimpleName() + " wait msg: " + message + " timeout " + (System.currentTimeMillis() - createtime) + "ms" + + (message.userid > 0 || (message.groupid != null && !message.groupid.isEmpty()) ? (message.userid > 0 ? (", userid:" + message.userid) : (", groupid:" + message.groupid)) : "")); } public long getSeqid() {