io.openmessaging.joyqueue.producer.support

类 TransactionalResultAdapter

java.lang.Object

io.openmessaging.joyqueue.producer.support.TransactionalResultAdapter

所有已实现的接口:

io.openmessaging.producer.SendResult, io.openmessaging.producer.TransactionalResult

public class TransactionalResultAdapter
extends Object
implements io.openmessaging.producer.TransactionalResult

TransactionalResultAdapter author: gaohaoxiang date: 2019/2/19

构造器概要

构造器

构造器和说明
TransactionalResultAdapter(io.openmessaging.message.Message message, String transactionId, MessageProducer messageProducer)

方法概要

限定符和类型	方法和说明
void	commit()
String	messageId()
protected TransactionMessageProducer	prepare(io.openmessaging.message.Message message, String transactionId, MessageProducer messageProducer)
void	rollback()
String	transactionId()

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

TransactionalResultAdapter

public TransactionalResultAdapter(io.openmessaging.message.Message message,
                                  String transactionId,
                                  MessageProducer messageProducer)

方法详细资料

prepare

protected TransactionMessageProducer prepare(io.openmessaging.message.Message message,
                                             String transactionId,
                                             MessageProducer messageProducer)

transactionId

public String transactionId()

指定者:

transactionId 在接口中 io.openmessaging.producer.TransactionalResult

commit

public void commit()

指定者:

commit 在接口中 io.openmessaging.producer.TransactionalResult

rollback

public void rollback()

指定者:

rollback 在接口中 io.openmessaging.producer.TransactionalResult

messageId

public String messageId()

指定者:

messageId 在接口中 io.openmessaging.producer.SendResult