package com.yeshi.fanli.util.rocketmq;
|
|
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 RocketMQLocalTransactionChecker implements LocalTransactionChecker {
|
public RocketMQLocalTransactionChecker() {
|
|
}
|
|
@Override
|
public TransactionStatus check(Message msg) {
|
// TODO Auto-generated method stub
|
return null;
|
}
|
}
|
