[ISSUE #7779] Fix the selectOneMessageQueue to avoid change messageQu…

…eue permanently Co-authored-by: tianyan <tangtianwei.ttw@antgroup.com>
apache · Jan 25, 2024 · f9f5465 · f9f5465
1 parent 8d2c661
commit f9f5465
Showing 1 changed file with 1 addition and 5 deletions.
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
@@ -73,11 +73,7 @@ public MessageQueue selectOneMessageQueue(final TopicPublishInfo tpInfo, final S
                 if (writeQueueNums > 0) {
                     final MessageQueue mq = tpInfo.selectOneMessageQueue();
                     if (notBestBroker != null) {
-                        MessageQueue selectedMessageQueue = new MessageQueue();
-                        selectedMessageQueue.setTopic(mq.getTopic());
-                        selectedMessageQueue.setBrokerName(notBestBroker);
-                        selectedMessageQueue.setQueueId(tpInfo.getSendWhichQueue().incrementAndGet() % writeQueueNums);
-                        return selectedMessageQueue;
+                        return new MessageQueue(mq.getTopic(), notBestBroker, tpInfo.getSendWhichQueue().incrementAndGet() % writeQueueNums);
                     } else {
                         return mq;
                     }