[rocketmq] branch 5.0.0-alpha-static-topic updated: Fix

[dongeforever]

This is an automated email from the ASF dual-hosted git repository.

dongeforever pushed a commit to branch 5.0.0-alpha-static-topic
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/5.0.0-alpha-static-topic by 
this push:
     new 6133887  Fix
6133887 is described below

commit 61338871edc36c8c0eb4bb5a81a2b29dc53e4e94
Author: dongeforever <dongefore...@apache.org>
AuthorDate: Tue Nov 9 19:55:48 2021 +0800

    Fix
---
 .../apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
 
b/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
index 7719597..52a2d9c 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
@@ -721,11 +721,11 @@ public class DefaultMQProducerImpl implements 
MQProducerInner {
         final TopicPublishInfo topicPublishInfo,
         final long timeout) throws MQClientException, RemotingException, 
MQBrokerException, InterruptedException {
         long beginStartTime = System.currentTimeMillis();
-        String destBrokerName = 
this.mQClientFactory.getBrokerNameFromMessageQueue(mq);
-        String brokerAddr = 
this.mQClientFactory.findBrokerAddressInPublish(destBrokerName);
+        String brokerName = 
this.mQClientFactory.getBrokerNameFromMessageQueue(mq);
+        String brokerAddr = 
this.mQClientFactory.findBrokerAddressInPublish(brokerName);
         if (null == brokerAddr) {
             tryToFindTopicPublishInfo(mq.getTopic());
-            brokerAddr = 
this.mQClientFactory.findBrokerAddressInPublish(destBrokerName);
+            brokerAddr = 
this.mQClientFactory.findBrokerAddressInPublish(brokerName);
         }
 
         SendMessageContext context = null;