org.joyqueue.client.internal.producer

接口 TransactionMessageProducer

所有已知实现类:

DefaultTransactionMessageProducer

public interface TransactionMessageProducer

TransactionMessageProducer author: gaohaoxiang date: 2018/12/10

方法概要

限定符和类型	方法和说明
List<SendResult>	batchSend(List<ProduceMessage> messages)
List<SendResult>	batchSend(List<ProduceMessage> messages, long timeout, TimeUnit timeoutUnit)
void	commit()
void	rollback()
SendResult	send(ProduceMessage message)
SendResult	send(ProduceMessage message, long timeout, TimeUnit timeoutUnit)

方法详细资料

commit

void commit()

rollback

void rollback()

send

SendResult send(ProduceMessage message)

send

SendResult send(ProduceMessage message,
                long timeout,
                TimeUnit timeoutUnit)

batchSend

List<SendResult> batchSend(List<ProduceMessage> messages)

batchSend

List<SendResult> batchSend(List<ProduceMessage> messages,
                           long timeout,
                           TimeUnit timeoutUnit)