From 6c5fc49de753423f0b4ba8fead798c64161c964d Mon Sep 17 00:00:00 2001
From: Heng Du <duheng0522@gmail.com>
Date: Wed, 12 Jun 2019 20:00:14 +0800
Subject: [PATCH] Add namespace support for transaction message (#1254)

---
 .../apache/rocketmq/client/producer/TransactionMQProducer.java   | 1 +
 1 file changed, 1 insertion(+)

diff --git a/client/src/main/java/org/apache/rocketmq/client/producer/TransactionMQProducer.java b/client/src/main/java/org/apache/rocketmq/client/producer/TransactionMQProducer.java
index 9873aca8..63b512df 100644
--- a/client/src/main/java/org/apache/rocketmq/client/producer/TransactionMQProducer.java
+++ b/client/src/main/java/org/apache/rocketmq/client/producer/TransactionMQProducer.java
@@ -86,6 +86,7 @@ public class TransactionMQProducer extends DefaultMQProducer {
             throw new MQClientException("TransactionListener is null", null);
         }
 
+        msg.setTopic(NamespaceUtil.wrapNamespace(this.getNamespace(), msg.getTopic()));
         return this.defaultMQProducerImpl.sendMessageInTransaction(msg, null, arg);
     }
 
-- 
GitLab