public class RocketmqTransactionListener extends java.lang.Object implements EventTranListener
| 构造器和说明 |
|---|
RocketmqTransactionListener(org.apache.rocketmq.client.apis.producer.Transaction transaction) |
| 限定符和类型 | 方法和说明 |
|---|---|
org.apache.rocketmq.client.apis.producer.Transaction |
getTransaction() |
void |
onCommit()
事务提交时
|
void |
onRollback()
事务回滚时
|
public RocketmqTransactionListener(org.apache.rocketmq.client.apis.producer.Transaction transaction)
public org.apache.rocketmq.client.apis.producer.Transaction getTransaction()
public void onCommit()
throws java.lang.Exception
EventTranListeneronCommit 在接口中 EventTranListenerjava.lang.Exceptionpublic void onRollback()
throws java.lang.Exception
EventTranListeneronRollback 在接口中 EventTranListenerjava.lang.Exception