This commit is contained in:
@@ -64,9 +64,9 @@ public abstract class MessageClient {
|
|||||||
node.future.complete(msg);
|
node.future.complete(msg);
|
||||||
long cha = now - msg.createtime;
|
long cha = now - msg.createtime;
|
||||||
if (cha > 50 || finer) {
|
if (cha > 50 || finer) {
|
||||||
messageAgent.logger.log(Level.FINER, "MessageRespFutureNode.process (mq.delay = " + cha + "ms) message: " + message);
|
messageAgent.logger.log(Level.FINER, "MessageRespFutureNode.process (mq.delay = " + cha + "ms) message: " + msg);
|
||||||
} else if (finest) {
|
} else if (finest) {
|
||||||
messageAgent.logger.log(Level.FINEST, "MessageRespFutureNode.process (mq.delay = " + cha + "ms) message: " + message);
|
messageAgent.logger.log(Level.FINEST, "MessageRespFutureNode.process (mq.delay = " + cha + "ms) message: " + msg);
|
||||||
}
|
}
|
||||||
|
|
||||||
};
|
};
|
||||||
|
|||||||
Reference in New Issue
Block a user