This change introduces a new annotation @RocketMQTransactionListener, which is declared on a class that implements from interface org.apache.rocketmq.client.producer.TransactionListener. At runtime, the annotation is responsible for creating a spring bean and implicitly creating and startup a TransactionMQProducer.
The user can send transactional message with the following API method and automatically callback the TransactionListener methods defined in the spring bean annotated by above @RocketMQTransactionListener: SendResult sendResult = rocketMQTemplate.sendMessageInTransaction(transName, msg, null); [ Full content available at: https://github.com/apache/rocketmq-externals/pull/102 ] This message was relayed via gitbox.apache.org for [email protected]
