bug修改

admin

2021-09-30 42411e4a26461229c6bca6e89ca55e98a80f5a4e

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

}