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

jinrongtong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-spring.git


The following commit(s) were added to refs/heads/master by this push:
     new 4727f0d  [ISSUE #484] Fix testExtRocketMQTemplate
4727f0d is described below

commit 4727f0d8dcd235410ea752f627a6e4913f93099d
Author: zhaohai <[email protected]>
AuthorDate: Tue Sep 6 22:32:36 2022 +0800

    [ISSUE #484] Fix testExtRocketMQTemplate
---
 .../rocketmq/spring/autoconfigure/ExtProducerResetConfiguration.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/autoconfigure/ExtProducerResetConfiguration.java
 
b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/autoconfigure/ExtProducerResetConfiguration.java
index f55ca35..570df1d 100644
--- 
a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/autoconfigure/ExtProducerResetConfiguration.java
+++ 
b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/autoconfigure/ExtProducerResetConfiguration.java
@@ -127,7 +127,7 @@ public class ExtProducerResetConfiguration implements 
ApplicationContextAware, S
         
producer.setCompressMsgBodyOverHowmuch(annotation.compressMessageBodyThreshold()
 == -1 ? producerConfig.getCompressMessageBodyThreshold() : 
annotation.compressMessageBodyThreshold());
         
producer.setRetryAnotherBrokerWhenNotStoreOK(annotation.retryNextServer());
         producer.setUseTLS(useTLS);
-        
producer.setNamespace(RocketMQUtil.getNamespace(annotation.namespace(), 
rocketMQProperties.getProducer().getNamespace()));
+        
producer.setNamespace(RocketMQUtil.getNamespace(annotation.namespace(), 
producerConfig.getNamespace()));
         producer.setInstanceName(annotation.instanceName());
         return producer;
     }

Reply via email to