工具类优化

admin

2021-02-06 d1f26741bddf6f512d62c0100d42c52be8d37e76

 fanli/src/main/java/com/yeshi/fanli/util/rocketmq/MyTransactionProducer.java

@@ -1,14 +1,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);

   }



}

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

}