提交 6c5fc49d 编写于 作者: H Heng Du 提交者: dinglei

Add namespace support for transaction message (#1254)

上级 5e6c21f7
......@@ -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);
}
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册