rocketmq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ding...@apache.org
Subject [rocketmq] branch develop updated: Add namespace support for transaction message (#1254)
Date Wed, 12 Jun 2019 12:00:21 GMT
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);
     }
 


Mime
View raw message