2.0.6

yujian

2019-12-25 a3ead770c30b310b9b1b7e3786d5d847da540e55

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); 
    } 
 
}