commit | 23690b8c45980542ec2c6bc11e1158b22b2c3652 | [log] [tgz] |
---|---|---|
author | rongtongjin <794220751@qq.com> | Thu Oct 31 15:19:19 2019 +0800 |
committer | rongtongjin <794220751@qq.com> | Thu Oct 31 15:19:19 2019 +0800 |
tree | f0e3e34a954c4fe1ec873dc3c3cd5fa727725bd8 | |
parent | 71a1e9c0fdb182486675eb7095cd2e0899a50ab5 [diff] |
fix(transaction):fix transactionProducer has incorrect namespace
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 @@ } txProducer.setTransactionListener(RocketMQUtil.convert(transactionListener)); + txProducer.setNamespace(producer.getNamespace()); txProducer.setNamesrvAddr(producer.getNamesrvAddr()); if (executorService != null) { txProducer.setExecutorService(executorService);