org.joyqueue.client.internal.producer

接口 MessageProducer

所有超级接口:

LifeCycle, Online

所有已知实现类:

DefaultMessageProducer, MessageProducerWrapper

public interface MessageProducer
extends LifeCycle

MessageProducer author: gaohaoxiang date: 2018/12/10

方法概要

限定符和类型	方法和说明
void	addInterceptor(ProducerInterceptor interceptor)
List<SendResult>	batchSend(List<ProduceMessage> messages)
List<SendResult>	batchSend(List<ProduceMessage> messages, long timeout, TimeUnit timeoutUnit)
CompletableFuture<List<SendResult>>	batchSendAsync(List<ProduceMessage> messages)
CompletableFuture<List<SendResult>>	batchSendAsync(List<ProduceMessage> messages, long timeout, TimeUnit timeoutUnit)
void	batchSendOneway(List<ProduceMessage> messages)
void	batchSendOneway(List<ProduceMessage> messages, long timeout, TimeUnit timeoutUnit)
TransactionMessageProducer	beginTransaction()
TransactionMessageProducer	beginTransaction(long timeout, TimeUnit timeoutUnit)
TransactionMessageProducer	beginTransaction(String transactionId)
TransactionMessageProducer	beginTransaction(String transactionId, long timeout, TimeUnit timeoutUnit)
TopicMetadata	getTopicMetadata(String topic)
void	removeInterceptor(ProducerInterceptor interceptor)
SendResult	send(ProduceMessage message)
SendResult	send(ProduceMessage message, long timeout, TimeUnit timeoutUnit)
CompletableFuture<SendResult>	sendAsync(ProduceMessage message)
CompletableFuture<SendResult>	sendAsync(ProduceMessage message, long timeout, TimeUnit timeoutUnit)
void	sendOneway(ProduceMessage message)
void	sendOneway(ProduceMessage message, long timeout, TimeUnit timeoutUnit)

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

start, stop

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

isStarted

方法详细资料

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)

sendOneway

void sendOneway(ProduceMessage message)

sendOneway

void sendOneway(ProduceMessage message,
                long timeout,
                TimeUnit timeoutUnit)

batchSendOneway

void batchSendOneway(List<ProduceMessage> messages)

batchSendOneway

void batchSendOneway(List<ProduceMessage> messages,
                     long timeout,
                     TimeUnit timeoutUnit)

sendAsync

CompletableFuture<SendResult> sendAsync(ProduceMessage message)

sendAsync

CompletableFuture<SendResult> sendAsync(ProduceMessage message,
                                        long timeout,
                                        TimeUnit timeoutUnit)

batchSendAsync

CompletableFuture<List<SendResult>> batchSendAsync(List<ProduceMessage> messages)

batchSendAsync

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

beginTransaction

TransactionMessageProducer beginTransaction()

beginTransaction

TransactionMessageProducer beginTransaction(long timeout,
                                            TimeUnit timeoutUnit)

beginTransaction

TransactionMessageProducer beginTransaction(String transactionId)

beginTransaction

TransactionMessageProducer beginTransaction(String transactionId,
                                            long timeout,
                                            TimeUnit timeoutUnit)

getTopicMetadata

TopicMetadata getTopicMetadata(String topic)

addInterceptor

void addInterceptor(ProducerInterceptor interceptor)

removeInterceptor

void removeInterceptor(ProducerInterceptor interceptor)