RocketMQ源码分析实战 - RocketMQLocalTransactionListener

package org.apache.rocketmq.spring.core;
import org.springframework.messaging.Message;
public interface RocketMQLocalTransactionListener {
  // 用来执行本地事务
    RocketMQLocalTransactionState executeLocalTransaction(final Message msg, final Object arg);
  // 本地事务的检查接口,即MQServer没有收到二次确认消息时调用的方法
  // 去检查本地事务到底有没有成功
    RocketMQLocalTransactionState checkLocalTransaction(final Message msg);
}