opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-24 16:04:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

Check producerTable or consumerTable is empty when updateTopicRouteInfoFromNameServer (#2581)

Browse Source
This commit is contained in:
赵延
2022-01-14 13:55:54 +08:00
committed by GitHub
parent 80bcfbc926
commit c5da66d841
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
+2 -2
View File
@@ -639,7 +639,7 @@ public class MQClientInstance {
}
// Update Pub info
{
if (!producerTable.isEmpty()) {
TopicPublishInfo publishInfo = topicRouteData2TopicPublishInfo(topic, topicRouteData);
publishInfo.setHaveTopicRouterInfo(true);
Iterator<Entry<String, MQProducerInner>> it = this.producerTable.entrySet().iterator();
@@ -653,7 +653,7 @@ public class MQClientInstance {
}
// Update sub info
{
if (!consumerTable.isEmpty()) {
Set<MessageQueue> subscribeInfo = topicRouteData2TopicSubscribeInfo(topic, topicRouteData);
Iterator<Entry<String, MQConsumerInner>> it = this.consumerTable.entrySet().iterator();
while (it.hasNext()) {