| 限定符和类型 | 方法和说明 |
|---|---|
static ProducerConfig |
KeyValueConverter.convertProducerConfig(io.openmessaging.KeyValue attributes) |
static ProducerConfig |
KeyValueConverter.convertProducerConfig(NameServerConfig nameServerConfig,
io.openmessaging.KeyValue attributes) |
| 限定符和类型 | 方法和说明 |
|---|---|
MessageProducer |
MessageAccessPoint.createProducer(ProducerConfig config) |
| 限定符和类型 | 方法和说明 |
|---|---|
static MessageProducer |
MessageProducerFactory.create(ProducerConfig producerConfig,
NameServerConfig nameServerConfig) |
static MessageProducer |
MessageProducerFactory.create(ProducerConfig producerConfig,
NameServerConfig nameServerConfig,
ClusterClientManager clusterClientManager,
ProducerClientManager producerClientManager) |
static MessageProducer |
MessageProducerFactory.create(ProducerConfig producerConfig,
NameServerConfig nameServerConfig,
ClusterManager clusterManager,
ProducerClientManager producerClientManager) |
static MessageProducer |
MessageProducerFactory.create(ProducerConfig producerConfig,
NameServerConfig nameServerConfig,
ProducerClientManager producerClientManager) |
static MessageProducer |
MessageProducerFactory.create(ProducerConfig producerConfig,
NameServerConfig nameServerConfig,
TransportConfig transportConfig) |
static MessageProducer |
MessageProducerFactory.create(ProducerConfig producerConfig,
NameServerConfig nameServerConfig,
TransportConfig transportConfig,
ProducerClientManager producerClientManager) |
| 限定符和类型 | 方法和说明 |
|---|---|
static void |
ProduceMessageChecker.checkMessage(ProduceMessage produceMessage,
ProducerConfig config) |
static void |
ProduceMessageChecker.checkMessages(List<ProduceMessage> produceMessages,
ProducerConfig config) |
| 限定符和类型 | 方法和说明 |
|---|---|
ProducerConfig |
ProducerConfig.copy() |
| 构造器和说明 |
|---|
ProducerInvocation(ProducerConfig config,
NameServerConfig nameServerConfig,
TopicMetadata topicMetadata,
List<ProduceMessage> messages,
ProducerInterceptorManager producerInterceptorManager,
ProducerInvoker producerInvoker) |
| 构造器和说明 |
|---|
DefaultMessageProducer(ProducerConfig config,
NameServerConfig nameServerConfig,
ClusterManager clusterManager,
ProducerClientManager producerClientManager) |
DefaultTransactionMessageProducer(String transactionId,
long timeout,
TimeUnit timeoutUnit,
long sequence,
ProducerConfig config,
NameServerConfig nameServerConfig,
ClusterManager clusterManager,
MessageSender messageSender,
MessageProducerInner messageProducerInner) |
MessageProducerInner(ProducerConfig config,
NameServerConfig nameServerConfig,
MessageSender messageSender,
ClusterManager clusterManager,
ProducerClientManager producerClientManager) |
MessageProducerInner(ProducerConfig config,
NameServerConfig nameServerConfig,
MessageSender messageSender,
ClusterManager clusterManager,
ProducerClientManager producerClientManager,
ProducerInterceptorManager producerInterceptorManager) |
| 限定符和类型 | 方法和说明 |
|---|---|
MessageProducer |
DefaultMessageAccessPoint.createProducer(ProducerConfig config) |
Copyright © 2020 Joyqueue Community. All rights reserved.