类的使用
org.joyqueue.client.internal.producer.domain.SendResult

使用SendResult的程序包

程序包	说明
io.openmessaging.joyqueue.producer.support
org.joyqueue.client.internal.producer
org.joyqueue.client.internal.producer.callback
org.joyqueue.client.internal.producer.domain
org.joyqueue.client.internal.producer.interceptor
org.joyqueue.client.internal.producer.support
org.joyqueue.client.internal.trace.interceptor

io.openmessaging.joyqueue.producer.support中SendResult的使用

参数类型为SendResult的io.openmessaging.joyqueue.producer.support中的方法

限定符和类型	方法和说明
static io.openmessaging.producer.SendResult	SendResultConverter.convert(SendResult sendResult)

类型变量类型为SendResult的io.openmessaging.joyqueue.producer.support中的方法参数

限定符和类型	方法和说明
static List<io.openmessaging.producer.SendResult>	SendResultConverter.convert(List<SendResult> sendResults)
void	ProducerInterceptorAdapter.postSend(ProduceContext context, List<SendResult> result)

参数类型为SendResult的io.openmessaging.joyqueue.producer.support中的构造器

构造器和说明
SendResultAdapter(SendResult sendResult)

org.joyqueue.client.internal.producer中SendResult的使用

返回SendResult的org.joyqueue.client.internal.producer中的方法

限定符和类型	方法和说明
SendResult	TransactionMessageProducer.send(ProduceMessage message)
SendResult	MessageProducer.send(ProduceMessage message)
SendResult	TransactionMessageProducer.send(ProduceMessage message, long timeout, TimeUnit timeoutUnit)
SendResult	MessageProducer.send(ProduceMessage message, long timeout, TimeUnit timeoutUnit)

返回变量类型为SendResult的类型的org.joyqueue.client.internal.producer中的方法

限定符和类型	方法和说明
List<SendResult>	TransactionMessageProducer.batchSend(List<ProduceMessage> messages)
List<SendResult>	MessageProducer.batchSend(List<ProduceMessage> messages)
List<SendResult>	TransactionMessageProducer.batchSend(List<ProduceMessage> messages, long timeout, TimeUnit timeoutUnit)
List<SendResult>	MessageProducer.batchSend(List<ProduceMessage> messages, long timeout, TimeUnit timeoutUnit)
CompletableFuture<List<SendResult>>	MessageProducer.batchSendAsync(List<ProduceMessage> messages)
CompletableFuture<List<SendResult>>	MessageProducer.batchSendAsync(List<ProduceMessage> messages, long timeout, TimeUnit timeoutUnit)
CompletableFuture<SendResult>	MessageProducer.sendAsync(ProduceMessage message)
CompletableFuture<SendResult>	MessageProducer.sendAsync(ProduceMessage message, long timeout, TimeUnit timeoutUnit)

org.joyqueue.client.internal.producer.callback中SendResult的使用

参数类型为SendResult的org.joyqueue.client.internal.producer.callback中的方法

限定符和类型	方法和说明
void	CompletableFutureAsyncProduceCallback.onSuccess(ProduceMessage message, SendResult result)
void	AsyncProduceCallback.onSuccess(ProduceMessage message, SendResult result)

类型变量类型为SendResult的org.joyqueue.client.internal.producer.callback中的方法参数

限定符和类型	方法和说明
void	CompletableFutureAsyncBatchProduceCallback.onSuccess(List<ProduceMessage> messages, List<SendResult> result)
void	AsyncBatchProduceCallback.onSuccess(List<ProduceMessage> messages, List<SendResult> result)
void	AsyncBatchProduceCallbackAdapter.onSuccess(List<ProduceMessage> messages, List<SendResult> result)

类型变量类型为SendResult的org.joyqueue.client.internal.producer.callback中的构造器参数

构造器和说明
CompletableFutureAsyncBatchProduceCallback(CompletableFuture<List<SendResult>> future)
CompletableFutureAsyncProduceCallback(CompletableFuture<SendResult> future)

org.joyqueue.client.internal.producer.domain中SendResult的使用

返回SendResult的org.joyqueue.client.internal.producer.domain中的方法

限定符和类型	方法和说明
SendResult	SendResultData.getResult()

返回变量类型为SendResult的类型的org.joyqueue.client.internal.producer.domain中的方法

限定符和类型	方法和说明
List<SendResult>	SendBatchResultData.getResult()

参数类型为SendResult的org.joyqueue.client.internal.producer.domain中的方法

限定符和类型	方法和说明
void	SendResultData.setResult(SendResult result)

类型变量类型为SendResult的org.joyqueue.client.internal.producer.domain中的方法参数

限定符和类型	方法和说明
void	SendBatchResultData.setResult(List<SendResult> result)

org.joyqueue.client.internal.producer.interceptor中SendResult的使用

返回变量类型为SendResult的类型的org.joyqueue.client.internal.producer.interceptor中的方法

限定符和类型	方法和说明
List<SendResult>	ProducerInvocation.invoke()
List<SendResult>	ProducerInvoker.invoke(ProduceContext context)
List<SendResult>	ProducerInvoker.reject(ProduceContext context)

类型变量类型为SendResult的org.joyqueue.client.internal.producer.interceptor中的方法参数

限定符和类型	方法和说明
void	ProducerInterceptor.postSend(ProduceContext context, List<SendResult> result)

org.joyqueue.client.internal.producer.support中SendResult的使用

返回SendResult的org.joyqueue.client.internal.producer.support中的方法

限定符和类型	方法和说明
protected SendResult	DefaultMessageProducer.doSend(ProduceMessage message, long timeout, TimeUnit timeoutUnit, boolean isOneway, AsyncProduceCallback callback)
SendResult	DefaultTransactionMessageProducer.send(ProduceMessage message)
SendResult	MessageProducerWrapper.send(ProduceMessage message)
SendResult	DefaultMessageProducer.send(ProduceMessage message)
SendResult	DefaultTransactionMessageProducer.send(ProduceMessage message, long timeout, TimeUnit timeoutUnit)
SendResult	MessageProducerWrapper.send(ProduceMessage message, long timeout, TimeUnit timeoutUnit)
SendResult	DefaultMessageProducer.send(ProduceMessage message, long timeout, TimeUnit timeoutUnit)
SendResult	MessageProducerInner.send(ProduceMessage message, String txId, long timeout, TimeUnit timeoutUnit, boolean isOneway, boolean failover, AsyncProduceCallback callback)

返回变量类型为SendResult的类型的org.joyqueue.client.internal.producer.support中的方法

限定符和类型	方法和说明
List<SendResult>	DefaultTransactionMessageProducer.batchSend(List<ProduceMessage> messages)
List<SendResult>	MessageProducerWrapper.batchSend(List<ProduceMessage> messages)
List<SendResult>	DefaultMessageProducer.batchSend(List<ProduceMessage> messages)
List<SendResult>	DefaultTransactionMessageProducer.batchSend(List<ProduceMessage> messages, long timeout, TimeUnit timeoutUnit)
List<SendResult>	MessageProducerWrapper.batchSend(List<ProduceMessage> messages, long timeout, TimeUnit timeoutUnit)
List<SendResult>	DefaultMessageProducer.batchSend(List<ProduceMessage> messages, long timeout, TimeUnit timeoutUnit)
List<SendResult>	MessageProducerInner.batchSend(List<ProduceMessage> messages, String txId, long timeout, TimeUnit timeoutUnit, boolean isOneway, boolean failover, AsyncBatchProduceCallback callback)
CompletableFuture<List<SendResult>>	MessageProducerWrapper.batchSendAsync(List<ProduceMessage> messages)
CompletableFuture<List<SendResult>>	DefaultMessageProducer.batchSendAsync(List<ProduceMessage> messages)
CompletableFuture<List<SendResult>>	MessageProducerWrapper.batchSendAsync(List<ProduceMessage> messages, long timeout, TimeUnit timeoutUnit)
CompletableFuture<List<SendResult>>	DefaultMessageProducer.batchSendAsync(List<ProduceMessage> messages, long timeout, TimeUnit timeoutUnit)
List<SendResult>	DefaultTransactionMessageProducer.doBatchSend(List<ProduceMessage> messages, long timeout, TimeUnit timeoutUnit)
protected List<SendResult>	DefaultMessageProducer.doBatchSend(List<ProduceMessage> messages, long timeout, TimeUnit timeoutUnit, boolean isOneway, AsyncBatchProduceCallback callback)
List<SendResult>	MessageProducerInner.doBatchSend(List<ProduceMessage> messages, String txId, long timeout, TimeUnit timeoutUnit, boolean isOneway, boolean failover, AsyncBatchProduceCallback callback)
List<SendResult>	MessageProducerInner.doBatchSend(List<ProduceMessage> messages, TopicMetadata topicMetadata, PartitionMetadata partition, List<PartitionMetadata> partitions, String txId, long timeout, TimeUnit timeoutUnit, boolean isOneway, boolean failover, AsyncBatchProduceCallback callback)
protected List<SendResult>	MessageProducerInner.doBatchSendInternal(List<ProduceMessage> messages, TopicMetadata topicMetadata, PartitionMetadata partition, List<PartitionMetadata> partitions, String txId, long timeout, TimeUnit timeoutUnit, boolean isOneway, boolean failover, AsyncBatchProduceCallback callback)
protected List<SendResult>	MessageProducerInner.doSendBatchMessage(BrokerNode brokerNode, String topic, String app, List<ProduceMessage> messages, String txId, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout, boolean isOneway, AsyncBatchProduceCallback callback)
protected List<SendResult>	MessageProducerInner.handleSendBatchResultData(String topic, String app, SendBatchResultData sendBatchResultData)
CompletableFuture<SendResult>	MessageProducerWrapper.sendAsync(ProduceMessage message)
CompletableFuture<SendResult>	DefaultMessageProducer.sendAsync(ProduceMessage message)
CompletableFuture<SendResult>	MessageProducerWrapper.sendAsync(ProduceMessage message, long timeout, TimeUnit timeoutUnit)
CompletableFuture<SendResult>	DefaultMessageProducer.sendAsync(ProduceMessage message, long timeout, TimeUnit timeoutUnit)

org.joyqueue.client.internal.trace.interceptor中SendResult的使用

类型变量类型为SendResult的org.joyqueue.client.internal.trace.interceptor中的方法参数

限定符和类型	方法和说明
void	TraceProducerInterceptor.postSend(ProduceContext context, List<SendResult> result)