checkTransactionState
oneWay
把 half 消息刷盘到 RMQ_SYS_TRANS_HALF_TOPIC
prepare
updateConsumeOffset
process normal msg
executeLocalTransaction
prepareMessage
Producer
TransactionalMessageBridge
发起 END_TRANSACTION
send(sync)
checkLocalTransactionState
SendMessageProcessor
每隔 60 秒执行一次
AbstractTransactionalMessageCheckListener
sendMessageInTransaction
ClientRemotingProcessor
EndTransactionProcessor
TransactionMQProducer
Container
TransactionalMessageServiceImpl
sendMessage
getHalfMessage
TransactionalMessageCheckService
putHalfMessage
sendCheckMessage
DefaultMQProducerImpl
fetchConsumeOffset
rollbackMessage
Broker
commitMessage
endTransaction
TRANSACTION_ROLLBACK_TYPE
TRANSACTION_NOT_TYPE
确认/回滚
回查
selectProducer
run
消息发送
check
TRANSACTION_COMMIT_TYPE
