This is an automated email from the ASF dual-hosted git repository.
duhengforever 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 23690b8 fix(transaction):fix transactionProducer has incorrect
namespace
new ab0406f Merge pull request #164 from RongtongJin/fix_namespace
23690b8 is described below
commit 23690b8c45980542ec2c6bc11e1158b22b2c3652
Author: rongtongjin <[email protected]>
AuthorDate: Thu Oct 31 15:19:19 2019 +0800
fix(transaction):fix transactionProducer has incorrect namespace
---
.../src/main/java/org/apache/rocketmq/spring/core/RocketMQTemplate.java | 1 +
1 file changed, 1 insertion(+)
diff --git
a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/core/RocketMQTemplate.java
b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/core/RocketMQTemplate.java
index be4d194..e70d304 100644
---
a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/core/RocketMQTemplate.java
+++
b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/core/RocketMQTemplate.java
@@ -660,6 +660,7 @@ public class RocketMQTemplate extends
AbstractMessageSendingTemplate<String> imp
}
txProducer.setTransactionListener(RocketMQUtil.convert(transactionListener));
+ txProducer.setNamespace(producer.getNamespace());
txProducer.setNamesrvAddr(producer.getNamesrvAddr());
if (executorService != null) {
txProducer.setExecutorService(executorService);