(rocketmq) branch develop updated: [ISSUE#6398] Remove duplicate code in TopicPublishInfo (#8034)

[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 63bb9e2a83 [ISSUE#6398] Remove duplicate code in TopicPublishInfo 
(#8034)
63bb9e2a83 is described below

commit 63bb9e2a839d4e0caadccce8553f89a249c5bbff
Author: shenyao <sy1028745...@hotmail.com>
AuthorDate: Thu Apr 18 15:41:39 2024 +0800

    [ISSUE#6398] Remove duplicate code in TopicPublishInfo (#8034)
    
    Co-authored-by: yao.s...@hstong.com <yao.s...@hstong.com>
---
 .../org/apache/rocketmq/client/impl/producer/TopicPublishInfo.java    | 4 +---
 1 file changed, 1 insertion(+), 3 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 37b1f3252f..917fe57aa8 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
@@ -111,9 +111,7 @@ public class TopicPublishInfo {
             return selectOneMessageQueue();
         } else {
             for (int i = 0; i < this.messageQueueList.size(); i++) {
-                int index = this.sendWhichQueue.incrementAndGet();
-                int pos = index % this.messageQueueList.size();
-                MessageQueue mq = this.messageQueueList.get(pos);
+                MessageQueue mq = selectOneMessageQueue();
                 if (!mq.getBrokerName().equals(lastBrokerName)) {
                     return mq;
                 }