org.joyqueue.client.internal.producer.support

类 DefaultMessageSender

java.lang.Object

org.joyqueue.toolkit.service.Activity

org.joyqueue.toolkit.service.Service

org.joyqueue.client.internal.producer.support.DefaultMessageSender

所有已实现的接口:

MessageSender, LifeCycle, Online

public class DefaultMessageSender
extends Service
implements MessageSender

DefaultMessageSender author: gaohaoxiang date: 2018/12/10

嵌套类概要

从类继承的嵌套类/接口 org.joyqueue.toolkit.service.Service

Service.Election, Service.ElectionListener

从类继承的嵌套类/接口 org.joyqueue.toolkit.service.Activity

Activity.ServiceState

字段概要

字段

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

从类继承的字段 org.joyqueue.toolkit.service.Activity

readLock, rwLock, serviceState, signal, started, writeLock

构造器概要

构造器

构造器和说明
DefaultMessageSender(ProducerClientManager producerClientManager, SenderConfig config)

方法概要

限定符和类型	方法和说明
Map<String,SendBatchResultData>	batchSend(BrokerNode brokerNode, String app, String txId, Map<String,List<ProduceMessage>> messages, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)
SendBatchResultData	batchSend(BrokerNode brokerNode, String topic, String app, String txId, List<ProduceMessage> messages, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)
CompletableFuture<Map<String,SendBatchResultData>>	batchSendAsync(BrokerNode brokerNode, String app, String txId, Map<String,List<ProduceMessage>> messages, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)
void	batchSendAsync(BrokerNode brokerNode, String app, String txId, Map<String,List<ProduceMessage>> messages, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout, AsyncMultiBatchSendCallback callback)
CompletableFuture<SendBatchResultData>	batchSendAsync(BrokerNode brokerNode, String topic, String app, String txId, List<ProduceMessage> messages, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)
void	batchSendAsync(BrokerNode brokerNode, String topic, String app, String txId, List<ProduceMessage> messages, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout, AsyncBatchSendCallback callback)
void	batchSendOneway(BrokerNode brokerNode, String app, String txId, Map<String,List<ProduceMessage>> messages, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)
void	batchSendOneway(BrokerNode brokerNode, String topic, String app, String txId, List<ProduceMessage> messages, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)
protected void	checkState()
org.joyqueue.exception.JoyQueueCode	commit(BrokerNode brokerNode, String topic, String app, String txId, long timeout)
protected void	doStop()
FetchFeedbackData	fetchFeedback(BrokerNode brokerNode, String topic, String app, TxStatus txStatus, int count, long longPollTimeout, long timeout)
protected void	handleAddProducers(BrokerNode brokerNode, Collection<String> topics, String app, ProducerClient client)
protected void	handleRemoveProducers()
protected void	handleRemoveProducers(BrokerNode brokerNode, Set<String> topics, Set<String> apps)
SendPrepareResult	prepare(BrokerNode brokerNode, String topic, String app, String transactionId, long sequence, long transactionTimeout, long timeout)
org.joyqueue.exception.JoyQueueCode	rollback(BrokerNode brokerNode, String topic, String app, String txId, long timeout)
SendResultData	send(BrokerNode brokerNode, String topic, String app, String txId, ProduceMessage message, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)
void	sendAsync(BrokerNode brokerNode, String topic, String app, String txId, ProduceMessage message, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout, AsyncSendCallback callback)
void	sendOneway(BrokerNode brokerNode, String topic, String app, String txId, ProduceMessage message, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)

从类继承的方法 org.joyqueue.toolkit.service.Service

getServiceState, isReady, isStarted, isStopped, start, stop, stop, validate, willStop

从类继承的方法 org.joyqueue.toolkit.service.Activity

afterStart, afterStop, await, beforeStart, beforeStop, convert, doStart, getReadLock, getWriteLock, startError

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

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

从接口继承的方法 org.joyqueue.toolkit.lang.LifeCycle

start, stop

从接口继承的方法 org.joyqueue.toolkit.lang.Online

isStarted

字段详细资料

logger

protected static final org.slf4j.Logger logger

构造器详细资料

DefaultMessageSender

public DefaultMessageSender(ProducerClientManager producerClientManager,
                            SenderConfig config)

方法详细资料

send

public SendResultData send(BrokerNode brokerNode,
                           String topic,
                           String app,
                           String txId,
                           ProduceMessage message,
                           org.joyqueue.domain.QosLevel qosLevel,
                           long produceTimeout,
                           long timeout)

指定者:

send 在接口中 MessageSender

batchSend

public SendBatchResultData batchSend(BrokerNode brokerNode,
                                     String topic,
                                     String app,
                                     String txId,
                                     List<ProduceMessage> messages,
                                     org.joyqueue.domain.QosLevel qosLevel,
                                     long produceTimeout,
                                     long timeout)

指定者:

batchSend 在接口中 MessageSender

sendAsync

public void sendAsync(BrokerNode brokerNode,
                      String topic,
                      String app,
                      String txId,
                      ProduceMessage message,
                      org.joyqueue.domain.QosLevel qosLevel,
                      long produceTimeout,
                      long timeout,
                      AsyncSendCallback callback)

指定者:

sendAsync 在接口中 MessageSender

batchSendAsync

public void batchSendAsync(BrokerNode brokerNode,
                           String topic,
                           String app,
                           String txId,
                           List<ProduceMessage> messages,
                           org.joyqueue.domain.QosLevel qosLevel,
                           long produceTimeout,
                           long timeout,
                           AsyncBatchSendCallback callback)

指定者:

batchSendAsync 在接口中 MessageSender

batchSendAsync

public CompletableFuture<SendBatchResultData> batchSendAsync(BrokerNode brokerNode,
                                                             String topic,
                                                             String app,
                                                             String txId,
                                                             List<ProduceMessage> messages,
                                                             org.joyqueue.domain.QosLevel qosLevel,
                                                             long produceTimeout,
                                                             long timeout)

指定者:

batchSendAsync 在接口中 MessageSender

sendOneway

public void sendOneway(BrokerNode brokerNode,
                       String topic,
                       String app,
                       String txId,
                       ProduceMessage message,
                       org.joyqueue.domain.QosLevel qosLevel,
                       long produceTimeout,
                       long timeout)

指定者:

sendOneway 在接口中 MessageSender

batchSendOneway

public void batchSendOneway(BrokerNode brokerNode,
                            String topic,
                            String app,
                            String txId,
                            List<ProduceMessage> messages,
                            org.joyqueue.domain.QosLevel qosLevel,
                            long produceTimeout,
                            long timeout)

指定者:

batchSendOneway 在接口中 MessageSender

batchSendOneway

public void batchSendOneway(BrokerNode brokerNode,
                            String app,
                            String txId,
                            Map<String,List<ProduceMessage>> messages,
                            org.joyqueue.domain.QosLevel qosLevel,
                            long produceTimeout,
                            long timeout)

指定者:

batchSendOneway 在接口中 MessageSender

batchSend

public Map<String,SendBatchResultData> batchSend(BrokerNode brokerNode,
                                                 String app,
                                                 String txId,
                                                 Map<String,List<ProduceMessage>> messages,
                                                 org.joyqueue.domain.QosLevel qosLevel,
                                                 long produceTimeout,
                                                 long timeout)

指定者:

batchSend 在接口中 MessageSender

batchSendAsync

public void batchSendAsync(BrokerNode brokerNode,
                           String app,
                           String txId,
                           Map<String,List<ProduceMessage>> messages,
                           org.joyqueue.domain.QosLevel qosLevel,
                           long produceTimeout,
                           long timeout,
                           AsyncMultiBatchSendCallback callback)

指定者:

batchSendAsync 在接口中 MessageSender

batchSendAsync

public CompletableFuture<Map<String,SendBatchResultData>> batchSendAsync(BrokerNode brokerNode,
                                                                         String app,
                                                                         String txId,
                                                                         Map<String,List<ProduceMessage>> messages,
                                                                         org.joyqueue.domain.QosLevel qosLevel,
                                                                         long produceTimeout,
                                                                         long timeout)

指定者:

batchSendAsync 在接口中 MessageSender

prepare

public SendPrepareResult prepare(BrokerNode brokerNode,
                                 String topic,
                                 String app,
                                 String transactionId,
                                 long sequence,
                                 long transactionTimeout,
                                 long timeout)

指定者:

prepare 在接口中 MessageSender

commit

public org.joyqueue.exception.JoyQueueCode commit(BrokerNode brokerNode,
                                                  String topic,
                                                  String app,
                                                  String txId,
                                                  long timeout)

指定者:

commit 在接口中 MessageSender

rollback

public org.joyqueue.exception.JoyQueueCode rollback(BrokerNode brokerNode,
                                                    String topic,
                                                    String app,
                                                    String txId,
                                                    long timeout)

指定者:

rollback 在接口中 MessageSender

fetchFeedback

public FetchFeedbackData fetchFeedback(BrokerNode brokerNode,
                                       String topic,
                                       String app,
                                       TxStatus txStatus,
                                       int count,
                                       long longPollTimeout,
                                       long timeout)

指定者:

fetchFeedback 在接口中 MessageSender

checkState

protected void checkState()

handleAddProducers

protected void handleAddProducers(BrokerNode brokerNode,
                                  Collection<String> topics,
                                  String app,
                                  ProducerClient client)

doStop

protected void doStop()

覆盖:

doStop 在类中 Activity

handleRemoveProducers

protected void handleRemoveProducers()

handleRemoveProducers

protected void handleRemoveProducers(BrokerNode brokerNode,
                                     Set<String> topics,
                                     Set<String> apps)