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

使用SendBatchResultData的程序包

程序包	说明
org.joyqueue.client.internal.producer
org.joyqueue.client.internal.producer.callback
org.joyqueue.client.internal.producer.converter
org.joyqueue.client.internal.producer.support

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

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

限定符和类型	方法和说明
SendBatchResultData	MessageSender.batchSend(BrokerNode brokerNode, String topic, String app, String txId, List<ProduceMessage> messages, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)
SendBatchResultData	MessageSenderWrapper.batchSend(BrokerNode brokerNode, String topic, String app, String txId, List<ProduceMessage> messages, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)

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

限定符和类型	方法和说明
Map<String,SendBatchResultData>	MessageSender.batchSend(BrokerNode brokerNode, String app, String txId, Map<String,List<ProduceMessage>> messages, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)
Map<String,SendBatchResultData>	MessageSenderWrapper.batchSend(BrokerNode brokerNode, String app, String txId, Map<String,List<ProduceMessage>> messages, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)
CompletableFuture<Map<String,SendBatchResultData>>	MessageSender.batchSendAsync(BrokerNode brokerNode, String app, String txId, Map<String,List<ProduceMessage>> messages, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)
CompletableFuture<Map<String,SendBatchResultData>>	MessageSenderWrapper.batchSendAsync(BrokerNode brokerNode, String app, String txId, Map<String,List<ProduceMessage>> messages, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)
CompletableFuture<SendBatchResultData>	MessageSender.batchSendAsync(BrokerNode brokerNode, String topic, String app, String txId, List<ProduceMessage> messages, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)
CompletableFuture<SendBatchResultData>	MessageSenderWrapper.batchSendAsync(BrokerNode brokerNode, String topic, String app, String txId, List<ProduceMessage> messages, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)

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

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

限定符和类型	方法和说明
void	AsyncBatchSendCallback.onSuccess(List<ProduceMessage> messages, SendBatchResultData result)

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

限定符和类型	方法和说明
void	AsyncMultiBatchSendCallback.onSuccess(Map<String,List<ProduceMessage>> messages, Map<String,SendBatchResultData> result)

org.joyqueue.client.internal.producer.converter中SendBatchResultData的使用

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

限定符和类型	方法和说明
static SendBatchResultData	MessageSenderConverter.convertToBatchResultData(String topic, String app, ProduceMessageAckData produceMessageAckData)

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

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

限定符和类型	方法和说明
SendBatchResultData	DefaultMessageSender.batchSend(BrokerNode brokerNode, String topic, String app, String txId, List<ProduceMessage> messages, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)

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

限定符和类型	方法和说明
Map<String,SendBatchResultData>	DefaultMessageSender.batchSend(BrokerNode brokerNode, String app, String txId, Map<String,List<ProduceMessage>> messages, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)
CompletableFuture<Map<String,SendBatchResultData>>	DefaultMessageSender.batchSendAsync(BrokerNode brokerNode, String app, String txId, Map<String,List<ProduceMessage>> messages, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)
CompletableFuture<SendBatchResultData>	DefaultMessageSender.batchSendAsync(BrokerNode brokerNode, String topic, String app, String txId, List<ProduceMessage> messages, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)

参数类型为SendBatchResultData的org.joyqueue.client.internal.producer.support中的方法

限定符和类型	方法和说明
protected List<SendResult>	MessageProducerInner.handleSendBatchResultData(String topic, String app, SendBatchResultData sendBatchResultData)