org.joyqueue.client.internal.producer.support

类 DefaultTransactionMessageProducer

java.lang.Object

org.joyqueue.client.internal.producer.support.DefaultTransactionMessageProducer

所有已实现的接口:

TransactionMessageProducer

public class DefaultTransactionMessageProducer
extends Object
implements TransactionMessageProducer

DefaultTransactionMessageProducer author: gaohaoxiang date: 2018/12/20

字段概要

字段

限定符和类型	字段和说明
protected static org.slf4j.Logger	logger

构造器概要

构造器

构造器和说明
DefaultTransactionMessageProducer(String transactionId, long timeout, TimeUnit timeoutUnit, long sequence, ProducerConfig config, NameServerConfig nameServerConfig, ClusterManager clusterManager, MessageSender messageSender, MessageProducerInner messageProducerInner)

方法概要

限定符和类型	方法和说明
List<SendResult>	batchSend(List<ProduceMessage> messages)
List<SendResult>	batchSend(List<ProduceMessage> messages, long timeout, TimeUnit timeoutUnit)
protected void	checkPrepare()
protected void	checkState()
void	commit()
List<SendResult>	doBatchSend(List<ProduceMessage> messages, long timeout, TimeUnit timeoutUnit)
protected SendPrepareResult	doPrepare(PartitionMetadata partition)
void	rollback()
SendResult	send(ProduceMessage message)
SendResult	send(ProduceMessage message, long timeout, TimeUnit timeoutUnit)

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

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

字段详细资料

logger

protected static final org.slf4j.Logger logger

构造器详细资料

DefaultTransactionMessageProducer

public DefaultTransactionMessageProducer(String transactionId,
                                         long timeout,
                                         TimeUnit timeoutUnit,
                                         long sequence,
                                         ProducerConfig config,
                                         NameServerConfig nameServerConfig,
                                         ClusterManager clusterManager,
                                         MessageSender messageSender,
                                         MessageProducerInner messageProducerInner)

方法详细资料

commit

public void commit()

指定者:

commit 在接口中 TransactionMessageProducer

rollback

public void rollback()

指定者:

rollback 在接口中 TransactionMessageProducer

send

public SendResult send(ProduceMessage message)

指定者:

send 在接口中 TransactionMessageProducer

send

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

指定者:

send 在接口中 TransactionMessageProducer

batchSend

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

指定者:

batchSend 在接口中 TransactionMessageProducer

batchSend

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

指定者:

batchSend 在接口中 TransactionMessageProducer

doBatchSend

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

doPrepare

protected SendPrepareResult doPrepare(PartitionMetadata partition)

checkPrepare

protected void checkPrepare()

checkState

protected void checkState()