package org.apache.rocketmq.ons.sample.producer; | |
import org.apache.rocketmq.ons.api.Message; | |
import org.apache.rocketmq.ons.api.transaction.LocalTransactionChecker; | |
import org.apache.rocketmq.ons.api.transaction.TransactionStatus; | |
public class LocalTransactionCheckerImpl implements LocalTransactionChecker { | |
@Override | |
public TransactionStatus check(Message msg) { | |
System.out.println("Receive transaction check back request, MsgId: " + msg.getMsgID()); | |
return TransactionStatus.CommitTransaction; | |
} | |
} |