You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by li...@apache.org on 2022/12/17 15:25:40 UTC
[rocketmq-clients] branch master updated: fix isolated endpoints in LoadBalancer (#316)
This is an automated email from the ASF dual-hosted git repository.
lizhimin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
The following commit(s) were added to refs/heads/master by this push:
new 850848d5 fix isolated endpoints in LoadBalancer (#316)
850848d5 is described below
commit 850848d567ff9ef581f94ffd26a5d645f62307a0
Author: guyinyou <36...@users.noreply.github.com>
AuthorDate: Sat Dec 17 23:25:36 2022 +0800
fix isolated endpoints in LoadBalancer (#316)
fix isolated endpoints in LoadBalancer
---
golang/loadBalancer.go | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/golang/loadBalancer.go b/golang/loadBalancer.go
index 1a5e0d8a..385b0653 100644
--- a/golang/loadBalancer.go
+++ b/golang/loadBalancer.go
@@ -105,7 +105,7 @@ func (plb *publishingLoadBalancer) TakeMessageQueues(excluded sync.Map, count in
broker := selectMessageQueue.Broker
brokerName := broker.GetName()
- if _, ok := candidateBrokerNames[brokerName]; !ok {
+ if _, ok := candidateBrokerNames[brokerName]; ok {
continue
}
candidates = append(candidates, selectMessageQueue)