This is an automated email from the ASF dual-hosted git repository.
dinglei pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new 6c5fc49 Add namespace support for transaction message (#1254)
6c5fc49 is described below
commit 6c5fc49de753423f0b4ba8fead798c64161c964d
Author: Heng Du <duheng0522@gmail.com>
AuthorDate: Wed Jun 12 20:00:14 2019 +0800
Add namespace support for transaction message (#1254)
---
.../java/org/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 9873aca..63b512d 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);
}
|