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