lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
Redkale
2021-01-10 10:33:48 +08:00
parent 67717e73ad
commit 4f32dcda16
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/org/redkale/mq/MessageClient.java
View File

@@ -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);
}
};