package com.yeshi.fanli.util.rocketmq.order;
|
|
import org.springframework.stereotype.Component;
|
|
import com.aliyun.openservices.ons.api.Message;
|
import com.aliyun.openservices.ons.api.transaction.LocalTransactionChecker;
|
import com.aliyun.openservices.ons.api.transaction.TransactionStatus;
|
|
@Component
|
public class RocketMQLocalOrderTransactionChecker implements LocalTransactionChecker {
|
public RocketMQLocalOrderTransactionChecker() {
|
|
}
|
|
@Override
|
public TransactionStatus check(Message msg) {
|
if (msg.getTag().startsWith("orderhongbao-")) {// 订单加入红包标识
|
return TransactionStatus.CommitTransaction;
|
}
|
return TransactionStatus.Unknow;
|
}
|
}
|
