org.joyqueue.client.internal.producer

类 MessageSenderWrapper

java.lang.Object

org.joyqueue.toolkit.service.Activity

org.joyqueue.toolkit.service.Service

org.joyqueue.client.internal.producer.MessageSenderWrapper

所有已实现的接口:

MessageSender, LifeCycle, Online

public class MessageSenderWrapper
extends Service
implements MessageSender

MessageSenderWrapper author: gaohaoxiang date: 2018/12/27

嵌套类概要

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

Service.Election, Service.ElectionListener

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

Activity.ServiceState

字段概要

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

readLock, rwLock, serviceState, signal, started, writeLock

构造器概要

构造器

构造器和说明
MessageSenderWrapper(ProducerClientManager producerClientManager, MessageSender delegate)

方法概要

限定符和类型	方法和说明
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)
org.joyqueue.exception.JoyQueueCode	commit(BrokerNode brokerNode, String topic, String app, String txId, long timeout)
protected void	doStart()
protected void	doStop()
FetchFeedbackData	fetchFeedback(BrokerNode brokerNode, String topic, String app, TxStatus txStatus, int count, long longPollTimeout, long timeout)
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, 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

构造器详细资料

MessageSenderWrapper

public MessageSenderWrapper(ProducerClientManager producerClientManager,
                            MessageSender delegate)

方法详细资料

doStart

protected void doStart()
                throws Exception

覆盖:

doStart 在类中 Activity

抛出:

Exception

doStop

protected void doStop()

覆盖:

doStop 在类中 Activity

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

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

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

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 app,
                            String txId,
                            Map<String,List<ProduceMessage>> messages,
                            org.joyqueue.domain.QosLevel qosLevel,
                            long produceTimeout,
                            long timeout)

指定者:

batchSendOneway 在接口中 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

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

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