Skip to content

Commit

Permalink
[ISSUE apache#7923] Exclude the master that are currently down
Browse files Browse the repository at this point in the history
Co-authored-by: fengwang219475 <[email protected]>
  • Loading branch information
zhuyuemufeng and fengwang219475 authored Mar 15, 2024
1 parent 333c545 commit 5eb0a8c
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -125,7 +125,7 @@ private SendResult putMessageToRemoteBroker(MessageExtBrokerInner messageExt) {
return null;
}

final MessageQueue mqSelected = topicPublishInfo.selectOneMessageQueue();
final MessageQueue mqSelected = topicPublishInfo.selectOneMessageQueue(this.brokerController.getBrokerConfig().getBrokerName());

messageToPut.setQueueId(mqSelected.getQueueId());

Expand Down

0 comments on commit 5eb0a8c

Please sign in to comment.