This is an automated email from the ASF dual-hosted git repository.
scarb 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 cb53fa572 remove (#6564)
cb53fa572 is described below
commit cb53fa572e01970c680578ca6502864b019ac1f3
Author: CoderBruis <[email protected]>
AuthorDate: Mon Apr 10 18:05:50 2023 +0800
remove (#6564)
Co-authored-by: haiyang.luo <[email protected]>
---
.../org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java | 2 --
1 file changed, 2 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 4677df690..db05eabba 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
@@ -225,8 +225,6 @@ public class DefaultMQProducerImpl implements
MQProducerInner {
null);
}
-
this.topicPublishInfoTable.put(this.defaultMQProducer.getCreateTopicKey(), new
TopicPublishInfo());
-
if (startFactory) {
mQClientFactory.start();
}