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-09 14:01:41 +08:00
parent 840cea06db
commit fb5f82c44f
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -63,7 +63,7 @@ public abstract class MessageClient {
long now = System.currentTimeMillis(); long now = System.currentTimeMillis();
MessageRespFutureNode node = respNodes.remove(msg.getSeqid()); MessageRespFutureNode node = respNodes.remove(msg.getSeqid());
if (node == null) { if (node == null) {
messageAgent.logger.log(Level.WARNING, MessageClient.this.getClass().getSimpleName() + " process " + msg + " error， not found mqmsg.respnode"); messageAgent.logger.log(Level.WARNING, MessageClient.this.getClass().getSimpleName() + " process " + msg + " error， not found mqresp.futurenode");
return; return;
} }
if (node.scheduledFuture != null) node.scheduledFuture.cancel(true); if (node.scheduledFuture != null) node.scheduledFuture.cancel(true);
@@ -72,11 +72,11 @@ public abstract class MessageClient {
node.future.complete(msg); node.future.complete(msg);
long cha = now - msg.createtime; long cha = now - msg.createtime;
if (cha > 1000 && fine) { if (cha > 1000 && fine) {
messageAgent.logger.log(Level.FINER, "MessageRespFutureNode.process (mqs.delays = " + cha + "ms) message: " + msg); messageAgent.logger.log(Level.FINE, "MessageRespFutureNode.process (mqs.delays = " + cha + "ms) mqresp.msg: " + msg);
} else if (cha > 50 && finer) { } else if (cha > 50 && finer) {
messageAgent.logger.log(Level.FINER, "MessageRespFutureNode.process (mq.delays = " + cha + "ms) message: " + msg); messageAgent.logger.log(Level.FINER, "MessageRespFutureNode.process (mq.delays = " + cha + "ms) mqresp.msg: " + msg);
} else if (finest) { } else if (finest) {
messageAgent.logger.log(Level.FINEST, "MessageRespFutureNode.process (mq.delay = " + cha + "ms) message: " + msg); messageAgent.logger.log(Level.FINEST, "MessageRespFutureNode.process (mq.delay = " + cha + "ms) mqresp.msg: " + msg);
} }
}; };