rocketmq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ding...@apache.org
Subject [rocketmq-client-go] branch native updated: fix(consumer): sub info not updated when scale out queue (#418)
Date Thu, 20 Feb 2020 02:49:24 GMT
This is an automated email from the ASF dual-hosted git repository.

dinglei pushed a commit to branch native
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-go.git


The following commit(s) were added to refs/heads/native by this push:
     new 8e6f902  fix(consumer): sub info not updated when scale out queue (#418)
8e6f902 is described below

commit 8e6f902f3d90f659d9b1c9918030adb2b3cd1c36
Author: xujianhai666 <52450794+xujianhai666@users.noreply.github.com>
AuthorDate: Thu Feb 20 10:49:17 2020 +0800

    fix(consumer): sub info not updated when scale out queue (#418)
    
    Closes #417 fix(consumer): sub info not updated when scale out queue
---
 internal/client.go | 3 ---
 1 file changed, 3 deletions(-)

diff --git a/internal/client.go b/internal/client.go
index 56bda03..f810b3a 100644
--- a/internal/client.go
+++ b/internal/client.go
@@ -679,9 +679,6 @@ func (c *rmqClient) updateSubscribeInfo(topic string, data *TopicRouteData,
chan
 	if data == nil {
 		return
 	}
-	if !c.isNeedUpdateSubscribeInfo(topic) {
-		return
-	}
 	c.consumerMap.Range(func(key, value interface{}) bool {
 		consumer := value.(InnerConsumer)
 		updated := changed


Mime
View raw message