You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by do...@apache.org on 2021/11/09 11:56:24 UTC
[rocketmq] branch 5.0.0-alpha-static-topic updated: Fix
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 <do...@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;