yujian
2020-04-02 0ec22dcf4fd9c4496e6f681e7fab89f56c6e4e8a
1
2
3
4
5
6
7
8
9
10
11
12
13
14
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);
    }
 
}