io.openmessaging.joyqueue.producer.support

类 ExtensionTransactionalResultAdapter

java.lang.Object

io.openmessaging.joyqueue.producer.support.ExtensionTransactionalResultAdapter

所有已实现的接口:

ExtensionTransactionalResult

public class ExtensionTransactionalResultAdapter
extends Object
implements ExtensionTransactionalResult

ExtensionTransactionalResultAdapter author: gaohaoxiang date: 2019/3/4

构造器概要

构造器

构造器和说明
ExtensionTransactionalResultAdapter(MessageProducer messageProducer)
ExtensionTransactionalResultAdapter(String transactionId, MessageProducer messageProducer)

方法概要

限定符和类型	方法和说明
protected List<ProduceMessage>	checkAndConvertMessage(List<io.openmessaging.message.Message> messages)
void	commit()
protected TransactionMessageProducer	prepare(String transactionId)
void	rollback()
List<io.openmessaging.producer.SendResult>	send(List<io.openmessaging.message.Message> messages)
io.openmessaging.producer.SendResult	send(io.openmessaging.message.Message message)
String	transactionId()

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

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

构造器详细资料

ExtensionTransactionalResultAdapter

public ExtensionTransactionalResultAdapter(MessageProducer messageProducer)

ExtensionTransactionalResultAdapter

public ExtensionTransactionalResultAdapter(String transactionId,
                                           MessageProducer messageProducer)

方法详细资料

prepare

protected TransactionMessageProducer prepare(String transactionId)

transactionId

public String transactionId()

指定者:

transactionId 在接口中 ExtensionTransactionalResult

commit

public void commit()

指定者:

commit 在接口中 ExtensionTransactionalResult

rollback

public void rollback()

指定者:

rollback 在接口中 ExtensionTransactionalResult

send

public io.openmessaging.producer.SendResult send(io.openmessaging.message.Message message)

指定者:

send 在接口中 ExtensionTransactionalResult

send

public List<io.openmessaging.producer.SendResult> send(List<io.openmessaging.message.Message> messages)

指定者:

send 在接口中 ExtensionTransactionalResult

checkAndConvertMessage

protected List<ProduceMessage> checkAndConvertMessage(List<io.openmessaging.message.Message> messages)