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-11-11 22:51:24 +08:00
parent 2f6eb0908e
commit bbefa788fd
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

@@ -80,7 +80,7 @@ public class HttpMessageProcessor implements MessageProcessor {
private void execute(final MessageRecord message, final Runnable callback) { private void execute(final MessageRecord message, final Runnable callback) {
HttpMessageRequest request = null; HttpMessageRequest request = null;
try { try {
if (finest) logger.log(Level.FINEST, "HttpMessageProcessor.process(mq.delay=" + (System.currentTimeMillis() - message.createtime) + "ms) message: " + message); if (finest) logger.log(Level.FINEST, "HttpMessageProcessor.process (mq.delay = " + (System.currentTimeMillis() - message.createtime) + " ms) message: " + message);
if (multiconsumer) message.setResptopic(null); //不容许有响应 if (multiconsumer) message.setResptopic(null); //不容许有响应
HttpContext context = server.getHttpServer().getContext(); HttpContext context = server.getHttpServer().getContext();
request = new HttpMessageRequest(context, message); request = new HttpMessageRequest(context, message);

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

@@ -59,7 +59,7 @@ public abstract class MessageClient {
AtomicLong ncer = node.getCounter(); AtomicLong ncer = node.getCounter();
if (ncer != null) ncer.decrementAndGet(); if (ncer != null) ncer.decrementAndGet();
node.future.complete(msg); node.future.complete(msg);
if (finest) messageAgent.logger.log(Level.FINEST, "MessageRespFutureNode.process(mq.delay=" + (now - msg.createtime) + "ms) message: " + message); if (finest) messageAgent.logger.log(Level.FINEST, "MessageRespFutureNode.process (mq.delay = " + (now - msg.createtime) + "ms) message: " + message);
}; };
MessageConsumer one = messageAgent.createConsumer(new String[]{respTopic}, respConsumerid, processor); MessageConsumer one = messageAgent.createConsumer(new String[]{respTopic}, respConsumerid, processor);