package cn.lili.common.listener;
|
|
import cn.lili.common.event.TransactionCommitSendMQEvent;
|
import cn.lili.rocketmq.RocketmqSendCallbackBuilder;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.rocketmq.spring.core.RocketMQTemplate;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
import org.springframework.transaction.event.TransactionPhase;
|
import org.springframework.transaction.event.TransactionalEventListener;
|
|
/**
|
* 事务提交监听器
|
*
|
* @author paulG
|
* @since 2022/1/19
|
**/
|
@Component
|
@Slf4j
|
public class TransactionCommitSendMQListener {
|
|
/**
|
* rocketMq
|
*/
|
@Autowired
|
private RocketMQTemplate rocketMQTemplate;
|
|
|
@TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
|
public void send(TransactionCommitSendMQEvent event) {
|
log.info("事务提交，发送mq信息!{}", event);
|
String destination = event.getTopic() + ":" + event.getTag();
|
//发送订单变更mq消息
|
rocketMQTemplate.asyncSend(destination, event.getMessage(), RocketmqSendCallbackBuilder.commonCallback());
|
}
|
|
|
}
|
