唯品会链接解析升级

admin

2024-04-26 5e7b0ed4a154ad067cbcf4aa1a1c7cce32f9864c

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

}