package com.yeshi.fanli.util.rocketmq;
|
|
import com.aliyun.openservices.ons.api.Message;
|
import com.aliyun.openservices.ons.api.SendResult;
|
import com.aliyun.openservices.ons.api.bean.TransactionProducerBean;
|
import com.aliyun.openservices.ons.api.transaction.LocalTransactionExecuter;
|
|
public class MyTransactionProducer extends TransactionProducerBean {
|
|
public SendResult sendMsg(Message message, LocalTransactionExecuter executer, Object arg) {
|
return super.send(message, executer, arg);
|
}
|
|
}
|
