[rocketmq] branch develop updated: [ISSUE ##7036] rename method: getWriteQueueIdByBroker to getWriteQueueNumsByBroker(#7037)

[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 804f2d85f2 [ISSUE ##7036] rename method: getWriteQueueIdByBroker to 
getWriteQueueNumsByBroker(#7037)
804f2d85f2 is described below

commit 804f2d85f22d9ee52573b9c6ee6abae248c9b387
Author: wenbin yao <ywb992...@163.com>
AuthorDate: Thu Jul 20 11:01:38 2023 +0800

    [ISSUE ##7036] rename method: getWriteQueueIdByBroker to 
getWriteQueueNumsByBroker(#7037)
    
    * [ISSUE ##7036] rename method: getWriteQueueIdByBroker to 
getWriteQueueNumsByBroker
    
    * [ISSUE #7036] rename method from getWriteQueueIdByBroker to 
getWriteQueueNumsByBroker
---
 .../java/org/apache/rocketmq/client/impl/producer/TopicPublishInfo.java | 2 +-
 .../main/java/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 a5f8405001..275ada7ac3 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 class TopicPublishInfo {
         return this.messageQueueList.get(pos);
     }
 
-    public int getWriteQueueIdByBroker(final String brokerName) {
+    public int getWriteQueueNumsByBroker(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 e86238e55b..1e1953fad9 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
@@ -69,7 +69,7 @@ public class MQFaultStrategy {
                 }
 
                 final String notBestBroker = 
latencyFaultTolerance.pickOneAtLeast();
-                int writeQueueNums = 
tpInfo.getWriteQueueIdByBroker(notBestBroker);
+                int writeQueueNums = 
tpInfo.getWriteQueueNumsByBroker(notBestBroker);
                 if (writeQueueNums > 0) {
                     final MessageQueue mq = tpInfo.selectOneMessageQueue();
                     if (notBestBroker != null) {