| 限定符和类型 | 类和说明 |
|---|---|
class |
OMSProduceMessage
OMSProduceMessage
author: gaohaoxiang
date: 2019/3/1
|
| 限定符和类型 | 方法和说明 |
|---|---|
ProduceMessage |
MessageAdapter.getProduceMessage() |
| 构造器和说明 |
|---|
MessageAdapter(ProduceMessage message) |
MessageExtensionHeaderAdapter(ProduceMessage message) |
MessageHeaderAdapter(ProduceMessage message) |
MessagePropertiesAdapter(ProduceMessage message) |
| 限定符和类型 | 方法和说明 |
|---|---|
protected List<ProduceMessage> |
ExtensionTransactionalResultAdapter.checkAndConvertMessage(List<io.openmessaging.message.Message> messages) |
protected List<ProduceMessage> |
ProducerImpl.checkAndConvertMessage(List<io.openmessaging.message.Message> messages) |
| 限定符和类型 | 方法和说明 |
|---|---|
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) |
| 限定符和类型 | 方法和说明 |
|---|---|
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) |
| 限定符和类型 | 方法和说明 |
|---|---|
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) |
| 限定符和类型 | 方法和说明 |
|---|---|
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) |
| 限定符和类型 | 方法和说明 |
|---|---|
static void |
ProduceMessageChecker.checkMessage(ProduceMessage produceMessage,
ProducerConfig config) |
| 限定符和类型 | 方法和说明 |
|---|---|
static void |
ProduceMessageChecker.checkMessages(List<ProduceMessage> produceMessages,
ProducerConfig config) |
| 限定符和类型 | 方法和说明 |
|---|---|
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) |
| 限定符和类型 | 方法和说明 |
|---|---|
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) |
| 限定符和类型 | 方法和说明 |
|---|---|
static void |
ProducerHelper.clearPartition(ProduceMessage message) |
| 限定符和类型 | 方法和说明 |
|---|---|
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) |
| 限定符和类型 | 方法和说明 |
|---|---|
List<ProduceMessage> |
ProduceContext.getMessages() |
| 构造器和说明 |
|---|
ProduceContext(String topic,
String app,
NameServerConfig nameserver,
List<ProduceMessage> messages) |
ProducerInvocation(ProducerConfig config,
NameServerConfig nameServerConfig,
TopicMetadata topicMetadata,
List<ProduceMessage> messages,
ProducerInterceptorManager producerInterceptorManager,
ProducerInvoker producerInvoker) |
| 限定符和类型 | 方法和说明 |
|---|---|
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) |
| 限定符和类型 | 方法和说明 |
|---|---|
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) |
Copyright © 2020 Joyqueue Community. All rights reserved.