From 2f93cbe051eb82834ee1ecba981c820a966190f3 Mon Sep 17 00:00:00 2001 From: loboxu Date: Sat, 18 Feb 2023 15:50:28 +0800 Subject: [PATCH] Optimize getQueueIdByBroker naming ambiguity --- .../apache/rocketmq/client/impl/producer/TopicPublishInfo.java | 2 +- .../org/apache/rocketmq/client/latency/MQFaultStrategy.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/producer/TopicPublishInfo.java b/client/src/main/java/org/apache/rocketmq/client/impl/producer/TopicPublishInfo.java index b7c4418d936..a5f8405001b 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/producer/TopicPublishInfo.java +++ b/client/src/main/java/org/apache/rocketmq/client/impl/producer/TopicPublishInfo.java @@ -89,7 +89,7 @@ public MessageQueue selectOneMessageQueue() { return this.messageQueueList.get(pos); } - public int getQueueIdByBroker(final String brokerName) { + public int getWriteQueueIdByBroker(final String brokerName) { for (int i = 0; i < topicRouteData.getQueueDatas().size(); i++) { final QueueData queueData = this.topicRouteData.getQueueDatas().get(i); if (queueData.getBrokerName().equals(brokerName)) { diff --git a/client/src/main/java/org/apache/rocketmq/client/latency/MQFaultStrategy.java b/client/src/main/java/org/apache/rocketmq/client/latency/MQFaultStrategy.java index 2b5cd914935..bd081868853 100644 --- a/client/src/main/java/org/apache/rocketmq/client/latency/MQFaultStrategy.java +++ b/client/src/main/java/org/apache/rocketmq/client/latency/MQFaultStrategy.java @@ -67,7 +67,7 @@ public MessageQueue selectOneMessageQueue(final TopicPublishInfo tpInfo, final S } final String notBestBroker = latencyFaultTolerance.pickOneAtLeast(); - int writeQueueNums = tpInfo.getQueueIdByBroker(notBestBroker); + int writeQueueNums = tpInfo.getWriteQueueIdByBroker(notBestBroker); if (writeQueueNums > 0) { final MessageQueue mq = tpInfo.selectOneMessageQueue(); if (notBestBroker != null) {