Hi, I am working on this issue (https://issues.apache.org/jira/browse/ROCKETMQ-123) as my GSOC project [ROCKETMQ-123] Support Distributed Transactional Messaging ...<https://issues.apache.org/jira/browse/ROCKETMQ-123> In most businesses, transactional messaging is frequently used to make a series of operations as an atomic transaction. At present, RocketMQ doesn't support ... issues.apache.org
However, there already have TransactionMQProducer https://github.com/apache/rocketmq/blob/master/client/src/main/java/org/apache/rocketmq/client/producer/TransactionMQProducer.java<https://github.com/apache/rocketmq/blob/master/client/src/main/java/org/apache/rocketmq/client/producer/TransactionMQProducer.java#L23> [https://avatars3.githubusercontent.com/u/47359?s=400&v=4]<https://github.com/apache/rocketmq/blob/master/client/src/main/java/org/apache/rocketmq/client/producer/TransactionMQProducer.java#L23> apache/rocketmq<https://github.com/apache/rocketmq/blob/master/client/src/main/java/org/apache/rocketmq/client/producer/TransactionMQProducer.java#L23> rocketmq - Mirror of Apache RocketMQ github.com and TransactionCheckListener https://github.com/apache/rocketmq/blob/master/client/src/main/java/org/apache/rocketmq/client/producer/TransactionCheckListener.java So, what is the part I should implement for this issue? Regards, Dexin Li
