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-06-14 01:21:26 +08:00
parent 1549f1feed
commit aa4c9896ba
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -87,7 +87,7 @@ public abstract class MessageClient {
if (counter != null) counter.incrementAndGet(); if (counter != null) counter.incrementAndGet();
getProducer().apply(message); getProducer().apply(message);
if (needresp) { if (needresp) {
MessageRespFutureNode node = new MessageRespFutureNode(message.getSeqid(),message, respNodes, counter, future); MessageRespFutureNode node = new MessageRespFutureNode(message, respNodes, counter, future);
respNodes.put(message.getSeqid(), node); respNodes.put(message.getSeqid(), node);
ScheduledThreadPoolExecutor executor = messageAgent.timeoutExecutor; ScheduledThreadPoolExecutor executor = messageAgent.timeoutExecutor;
if (executor != null) executor.schedule(node, 6, TimeUnit.SECONDS); if (executor != null) executor.schedule(node, 6, TimeUnit.SECONDS);

4
src/org/redkale/mq/MessageRespFutureNode.java
View File

@@ -30,8 +30,8 @@ public class MessageRespFutureNode implements Runnable {
protected final ConcurrentHashMap<Long, MessageRespFutureNode> respNodes; protected final ConcurrentHashMap<Long, MessageRespFutureNode> respNodes;
public MessageRespFutureNode(long seqid, ConcurrentHashMap<Long, MessageRespFutureNode> respNodes, AtomicLong counter, CompletableFuture<MessageRecord> future) { public MessageRespFutureNode(MessageRecord message, ConcurrentHashMap<Long, MessageRespFutureNode> respNodes, AtomicLong counter, CompletableFuture<MessageRecord> future) {
this.seqid = seqid; this.seqid = message.getSeqid();
this.respNodes = respNodes; this.respNodes = respNodes;
this.counter = counter; this.counter = counter;
this.future = future; this.future = future;