You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by di...@apache.org on 2020/02/20 02:49:24 UTC
[rocketmq-client-go] branch native updated: fix(consumer): sub info
not updated when scale out queue (#418)
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 <52...@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