[rocketmq-clients] branch master updated: fix isolated endpoints in LoadBalancer (#316)

[lizhimin]

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 <36399867+guyin...@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)