[ISSUE#6398] Remove duplicate code in TopicPublishInfo (apache#8034)

Co-authored-by: [email protected] <[email protected]>
Jianing-Xu · Apr 18, 2024 · 63bb9e2 · 63bb9e2
1 parent 9d07cc7
commit 63bb9e2
Showing 1 changed file with 1 addition and 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
@@ -111,9 +111,7 @@ public MessageQueue selectOneMessageQueue(final String lastBrokerName) {
             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;
                 }