org.joyqueue.client.internal.producer

接口 MessageSender

所有超级接口:

LifeCycle, Online

所有已知实现类:

DefaultMessageSender, MessageSenderWrapper

public interface MessageSender
extends LifeCycle

MessageSender author: gaohaoxiang date: 2018/12/10

方法概要

限定符和类型	方法和说明
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)
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.lang.LifeCycle

start, stop

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

isStarted

方法详细资料

send

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

batchSend

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

sendAsync

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

batchSendAsync

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

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

sendOneway

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

batchSendOneway

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

batchSendOneway

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

batchSend

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

batchSendAsync

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

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)

prepare

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

commit

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

rollback

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

fetchFeedback

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