订单消息bug修改

admin

2022-04-27 3340ed122e19e3943ce4f93eb52103b623a3fc2c

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

}