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

使用ProduceMessage的程序包

程序包	说明
io.openmessaging.joyqueue.producer.message
io.openmessaging.joyqueue.producer.support
org.joyqueue.client.internal.producer
org.joyqueue.client.internal.producer.callback
org.joyqueue.client.internal.producer.checker
org.joyqueue.client.internal.producer.converter
org.joyqueue.client.internal.producer.helper
org.joyqueue.client.internal.producer.interceptor
org.joyqueue.client.internal.producer.support

io.openmessaging.joyqueue.producer.message中ProduceMessage的使用

io.openmessaging.joyqueue.producer.message中ProduceMessage的子类

限定符和类型	类和说明
class	OMSProduceMessage OMSProduceMessage author: gaohaoxiang date: 2019/3/1

返回ProduceMessage的io.openmessaging.joyqueue.producer.message中的方法

限定符和类型	方法和说明
ProduceMessage	MessageAdapter.getProduceMessage()

参数类型为ProduceMessage的io.openmessaging.joyqueue.producer.message中的构造器

构造器和说明
MessageAdapter(ProduceMessage message)
MessageExtensionHeaderAdapter(ProduceMessage message)
MessageHeaderAdapter(ProduceMessage message)
MessagePropertiesAdapter(ProduceMessage message)

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

返回变量类型为ProduceMessage的类型的io.openmessaging.joyqueue.producer.support中的方法

限定符和类型	方法和说明
protected List<ProduceMessage>	ExtensionTransactionalResultAdapter.checkAndConvertMessage(List<io.openmessaging.message.Message> messages)
protected List<ProduceMessage>	ProducerImpl.checkAndConvertMessage(List<io.openmessaging.message.Message> messages)

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

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

限定符和类型	方法和说明
PartitionMetadata	PartitionSelector.select(ProduceMessage message, TopicMetadata topicMetadata, List<PartitionMetadata> partitions)
SendResultData	MessageSender.send(BrokerNode brokerNode, String topic, String app, String txId, ProduceMessage message, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)
SendResultData	MessageSenderWrapper.send(BrokerNode brokerNode, String topic, String app, String txId, ProduceMessage message, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)
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)
void	MessageSender.sendAsync(BrokerNode brokerNode, String topic, String app, String txId, ProduceMessage message, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout, AsyncSendCallback callback)
void	MessageSenderWrapper.sendAsync(BrokerNode brokerNode, String topic, String app, String txId, ProduceMessage message, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout, AsyncSendCallback callback)
CompletableFuture<SendResult>	MessageProducer.sendAsync(ProduceMessage message)
CompletableFuture<SendResult>	MessageProducer.sendAsync(ProduceMessage message, long timeout, TimeUnit timeoutUnit)
void	MessageSender.sendOneway(BrokerNode brokerNode, String topic, String app, String txId, ProduceMessage message, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)
void	MessageSenderWrapper.sendOneway(BrokerNode brokerNode, String topic, String app, String txId, ProduceMessage message, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)
void	MessageProducer.sendOneway(ProduceMessage message)
void	MessageProducer.sendOneway(ProduceMessage message, long timeout, TimeUnit timeoutUnit)

类型变量类型为ProduceMessage的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)
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)
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<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)
void	MessageSender.batchSendAsync(BrokerNode brokerNode, String app, String txId, Map<String,List<ProduceMessage>> messages, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout, AsyncMultiBatchSendCallback callback)
void	MessageSenderWrapper.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>	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)
void	MessageSender.batchSendAsync(BrokerNode brokerNode, String topic, String app, String txId, List<ProduceMessage> messages, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout, AsyncBatchSendCallback callback)
void	MessageSenderWrapper.batchSendAsync(BrokerNode brokerNode, String topic, String app, String txId, List<ProduceMessage> messages, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout, AsyncBatchSendCallback callback)
CompletableFuture<List<SendResult>>	MessageProducer.batchSendAsync(List<ProduceMessage> messages)
CompletableFuture<List<SendResult>>	MessageProducer.batchSendAsync(List<ProduceMessage> messages, long timeout, TimeUnit timeoutUnit)
void	MessageSender.batchSendOneway(BrokerNode brokerNode, String app, String txId, Map<String,List<ProduceMessage>> messages, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)
void	MessageSenderWrapper.batchSendOneway(BrokerNode brokerNode, String app, String txId, Map<String,List<ProduceMessage>> messages, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)
void	MessageSender.batchSendOneway(BrokerNode brokerNode, String topic, String app, String txId, List<ProduceMessage> messages, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)
void	MessageSenderWrapper.batchSendOneway(BrokerNode brokerNode, String topic, String app, String txId, List<ProduceMessage> messages, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)
void	MessageProducer.batchSendOneway(List<ProduceMessage> messages)
void	MessageProducer.batchSendOneway(List<ProduceMessage> messages, long timeout, TimeUnit timeoutUnit)

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

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

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

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

限定符和类型	方法和说明
void	AsyncBatchSendCallback.onException(List<ProduceMessage> messages, Throwable cause)
void	CompletableFutureAsyncBatchProduceCallback.onException(List<ProduceMessage> messages, Throwable cause)
void	AsyncBatchProduceCallback.onException(List<ProduceMessage> messages, Throwable cause)
void	AsyncBatchProduceCallbackAdapter.onException(List<ProduceMessage> messages, Throwable cause)
void	AsyncMultiBatchSendCallback.onException(Map<String,List<ProduceMessage>> messages, Throwable cause)
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)
void	AsyncBatchSendCallback.onSuccess(List<ProduceMessage> messages, SendBatchResultData result)
void	AsyncMultiBatchSendCallback.onSuccess(Map<String,List<ProduceMessage>> messages, Map<String,SendBatchResultData> result)

org.joyqueue.client.internal.producer.checker中ProduceMessage的使用

参数类型为ProduceMessage的org.joyqueue.client.internal.producer.checker中的方法

限定符和类型	方法和说明
static void	ProduceMessageChecker.checkMessage(ProduceMessage produceMessage, ProducerConfig config)

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

限定符和类型	方法和说明
static void	ProduceMessageChecker.checkMessages(List<ProduceMessage> produceMessages, ProducerConfig config)

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

参数类型为ProduceMessage的org.joyqueue.client.internal.producer.converter中的方法

限定符和类型	方法和说明
static org.joyqueue.message.BrokerMessage	ProduceMessageConverter.convertToBrokerMessage(String topic, String app, ProduceMessage produceMessage)
static org.joyqueue.message.BrokerMessage	ProduceMessageConverter.convertToBrokerMessage(String topic, String app, ProduceMessage produceMessage, boolean compress, int compressThreshold, String compressType)
protected static byte[]	ProduceMessageConverter.serializeBody(ProduceMessage produceMessage)

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

限定符和类型	方法和说明
static org.joyqueue.message.BrokerMessage	ProduceMessageConverter.convertToBatchBrokerMessage(String topic, String app, List<ProduceMessage> produceMessages, boolean compress, int compressThreshold, String compressType)
static List<org.joyqueue.message.BrokerMessage>	ProduceMessageConverter.convertToBrokerMessages(String topic, String app, List<ProduceMessage> produceMessages, boolean compress, int compressThreshold, String compressType)
static List<org.joyqueue.message.BrokerMessage>	ProduceMessageConverter.convertToBrokerMessages(String topic, String app, List<ProduceMessage> produceMessages, boolean compress, int compressThreshold, String compressType, boolean batch)
static ProduceMessageData	MessageSenderConverter.convertToProduceMessageData(String topic, String app, String txId, List<ProduceMessage> messages, org.joyqueue.domain.QosLevel qosLevel, long timeout, boolean compress, int compressThreshold, String compressType, boolean batch)

org.joyqueue.client.internal.producer.helper中ProduceMessage的使用

参数类型为ProduceMessage的org.joyqueue.client.internal.producer.helper中的方法

限定符和类型	方法和说明
static void	ProducerHelper.clearPartition(ProduceMessage message)

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

限定符和类型	方法和说明
static void	ProducerHelper.clearPartitions(List<ProduceMessage> messages)
static PartitionMetadata	ProducerHelper.dispatchPartitions(List<ProduceMessage> messages, TopicMetadata topicMetadata, List<PartitionMetadata> partitions, PartitionSelector partitionSelector)
static void	ProducerHelper.setPartitions(List<ProduceMessage> messages, short partition)

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

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

限定符和类型	方法和说明
List<ProduceMessage>	ProduceContext.getMessages()

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

构造器和说明
ProduceContext(String topic, String app, NameServerConfig nameserver, List<ProduceMessage> messages)
ProducerInvocation(ProducerConfig config, NameServerConfig nameServerConfig, TopicMetadata topicMetadata, List<ProduceMessage> messages, ProducerInterceptorManager producerInterceptorManager, ProducerInvoker producerInvoker)

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

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

限定符和类型	方法和说明
protected SendResult	DefaultMessageProducer.doSend(ProduceMessage message, long timeout, TimeUnit timeoutUnit, boolean isOneway, AsyncProduceCallback callback)
protected PartitionMetadata	AbstractPartitionSelector.hashPartition(ProduceMessage message, TopicMetadata topicMetadata, List<PartitionMetadata> partitions)
protected abstract PartitionMetadata	AbstractPartitionSelector.nextPartition(ProduceMessage message, TopicMetadata topicMetadata, List<PartitionMetadata> partitions)
protected PartitionMetadata	WeightedRoundRobinPartitionSelector.nextPartition(ProduceMessage message, TopicMetadata topicMetadata, List<PartitionMetadata> partitions)
PartitionMetadata	AbstractPartitionSelector.select(ProduceMessage message, TopicMetadata topicMetadata, List<PartitionMetadata> partitions)
protected PartitionMetadata	AbstractPartitionSelector.selectPartition(ProduceMessage message, TopicMetadata topicMetadata, List<PartitionMetadata> partitions)
SendResultData	DefaultMessageSender.send(BrokerNode brokerNode, String topic, String app, String txId, ProduceMessage message, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)
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)
void	DefaultMessageSender.sendAsync(BrokerNode brokerNode, String topic, String app, String txId, ProduceMessage message, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout, AsyncSendCallback callback)
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)
void	DefaultMessageSender.sendOneway(BrokerNode brokerNode, String topic, String app, String txId, ProduceMessage message, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)
void	MessageProducerWrapper.sendOneway(ProduceMessage message)
void	DefaultMessageProducer.sendOneway(ProduceMessage message)
void	MessageProducerWrapper.sendOneway(ProduceMessage message, long timeout, TimeUnit timeoutUnit)
void	DefaultMessageProducer.sendOneway(ProduceMessage message, long timeout, TimeUnit timeoutUnit)

类型变量类型为ProduceMessage的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)
SendBatchResultData	DefaultMessageSender.batchSend(BrokerNode brokerNode, String topic, String app, String txId, List<ProduceMessage> messages, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)
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<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)
void	DefaultMessageSender.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>	DefaultMessageSender.batchSendAsync(BrokerNode brokerNode, String topic, String app, String txId, List<ProduceMessage> messages, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)
void	DefaultMessageSender.batchSendAsync(BrokerNode brokerNode, String topic, String app, String txId, List<ProduceMessage> messages, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout, AsyncBatchSendCallback 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)
void	DefaultMessageSender.batchSendOneway(BrokerNode brokerNode, String app, String txId, Map<String,List<ProduceMessage>> messages, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)
void	DefaultMessageSender.batchSendOneway(BrokerNode brokerNode, String topic, String app, String txId, List<ProduceMessage> messages, org.joyqueue.domain.QosLevel qosLevel, long produceTimeout, long timeout)
void	MessageProducerWrapper.batchSendOneway(List<ProduceMessage> messages)
void	DefaultMessageProducer.batchSendOneway(List<ProduceMessage> messages)
void	MessageProducerWrapper.batchSendOneway(List<ProduceMessage> messages, long timeout, TimeUnit timeoutUnit)
void	DefaultMessageProducer.batchSendOneway(List<ProduceMessage> messages, long timeout, TimeUnit timeoutUnit)
PartitionMetadata	MessageProducerInner.dispatchPartitions(List<ProduceMessage> messages, TopicMetadata topicMetadata, List<PartitionMetadata> partitions)
PartitionMetadata	MessageProducerInner.dispatchPartitions(List<ProduceMessage> messages, TopicMetadata topicMetadata, List<PartitionMetadata> partitions, List<PartitionMetadata> blackPartitionList)
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)
boolean	MessageProducerInner.isFailover(List<ProduceMessage> messages)