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-04 20:56:45 +08:00
parent b4f7de4858
commit 06b7274364
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -76,12 +76,12 @@ public abstract class MessageAgent {
if (node.consumer.topic.length() > maxlen.get()) maxlen.set(node.consumer.topic.length()); if (node.consumer.topic.length() > maxlen.get()) maxlen.set(node.consumer.topic.length());
}); });
if (this.sncpRespStartms >= 0) { if (this.sncpRespStartms >= 0) {
sb.append("MessageConsumer(topic=").append(fillString(this.sncpRespConsumer.topic, maxlen.get())).append(") init and start in ").append(this.sncpRespStartms).append(" ms\r\n"); if (sb != null) sb.append("MessageConsumer(topic=").append(fillString(this.sncpRespConsumer.topic, maxlen.get())).append(") init and start in ").append(this.sncpRespStartms).append(" ms\r\n");
} }
this.messageNodes.values().forEach(node -> { this.messageNodes.values().forEach(node -> {
long s = System.currentTimeMillis(); long s = System.currentTimeMillis();
node.consumer.startup().join(); node.consumer.startup().join();
sb.append("MessageConsumer(topic=").append(fillString(node.consumer.topic, maxlen.get())).append(") init and start in ").append(System.currentTimeMillis() - s).append(" ms\r\n"); if (sb != null) sb.append("MessageConsumer(topic=").append(fillString(node.consumer.topic, maxlen.get())).append(") init and start in ").append(System.currentTimeMillis() - s).append(" ms\r\n");
}); });
return CompletableFuture.completedFuture(null); return CompletableFuture.completedFuture(null);
} }