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();
                 }

Reply via email to