接口的使用
org.joyqueue.client.internal.producer.callback.AsyncBatchProduceCallback

使用AsyncBatchProduceCallback的程序包

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

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

实现AsyncBatchProduceCallback的org.joyqueue.client.internal.producer.callback中的类

限定符和类型	类和说明
class	AsyncBatchProduceCallbackAdapter AsyncBatchProduceCallbackAdapter author: gaohaoxiang date: 2018/12/27
class	CompletableFutureAsyncBatchProduceCallback CompletableFutureAsyncBatchProduceCallback author: gaohaoxiang date: 2019/7/25

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

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

限定符和类型	方法和说明
List<SendResult>	MessageProducerInner.batchSend(List<ProduceMessage> messages, String txId, long timeout, TimeUnit timeoutUnit, boolean isOneway, boolean failover, AsyncBatchProduceCallback callback)
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)