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

Browse Source
This commit is contained in:
Redkale
2020-12-15 21:55:32 +08:00
parent 612bfcba37
commit 7e777229ba
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/org/redkale/mq/HttpMessageProcessor.java
View File

@@ -85,7 +85,7 @@ public class HttpMessageProcessor implements MessageProcessor {
try {
long cha = System.currentTimeMillis() - message.createtime;
if (cha > 50 || finer) {
logger.log(Level.FINER, "HttpMessageProcessor.process (mq.delay = " + cha + " ms) message: " + message);
logger.log(Level.FINER, "HttpMessageProcessor.process (mq.delays = " + cha + " ms) message: " + message);
} else if (finest) {
logger.log(Level.FINEST, "HttpMessageProcessor.process (mq.delay = " + cha + " ms) message: " + message);
}

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

@@ -64,7 +64,7 @@ public abstract class MessageClient {
node.future.complete(msg);
long cha = now - msg.createtime;
if (cha > 50 || finer) {
messageAgent.logger.log(Level.FINER, "MessageRespFutureNode.process (mq.delay = " + cha + "ms) message: " + msg);
messageAgent.logger.log(Level.FINER, "MessageRespFutureNode.process (mq.delays = " + cha + "ms) message: " + msg);
} else if (finest) {
messageAgent.logger.log(Level.FINEST, "MessageRespFutureNode.process (mq.delay = " + cha + "ms) message: " + msg);
}