[rocketmq-spring] branch master updated: fix(transaction):fix transactionProducer has incorrect namespace

[du...@apache.org]

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 <79...@qq.com>
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);