(rocketmq) branch develop updated: [ISSUE #7923] Exclude the master that are currently down

[jinrongtong]

This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 5eb0a8ce0f [ISSUE #7923] Exclude the master that are currently down
5eb0a8ce0f is described below

commit 5eb0a8ce0fe7476becf000af20064eae9ea5c9b4
Author: mufeng <51144340+zhuyuemuf...@users.noreply.github.com>
AuthorDate: Fri Mar 15 13:53:58 2024 +0800

    [ISSUE #7923] Exclude the master that are currently down
    
    Co-authored-by: fengwang219475 <fengwang219...@sohu-inc.com>
---
 .../src/main/java/org/apache/rocketmq/broker/failover/EscapeBridge.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/failover/EscapeBridge.java 
b/broker/src/main/java/org/apache/rocketmq/broker/failover/EscapeBridge.java
index 6a08174801..ededaf2c65 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/failover/EscapeBridge.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/failover/EscapeBridge.java
@@ -125,7 +125,7 @@ public class EscapeBridge {
             return null;
         }
 
-        final MessageQueue mqSelected = 
topicPublishInfo.selectOneMessageQueue();
+        final MessageQueue mqSelected = 
topicPublishInfo.selectOneMessageQueue(this.brokerController.getBrokerConfig().getBrokerName());
 
         messageToPut.setQueueId(mqSelected.getQueueId());