| 限定符和类型 | 方法和说明 |
|---|---|
static MessageSender |
MessageSenderFactory.create(ProducerClientManager producerClientManager,
SenderConfig config) |
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,
ProducerClientManager producerClientManager) |
static TxFeedbackManager |
TxFeedbackManagerFactory.create(TxFeedbackConfig config,
NameServerConfig nameServerConfig,
ClusterManager clusterManager,
ProducerClientManager producerClientManager) |
| 构造器和说明 |
|---|
MessageSenderWrapper(ProducerClientManager producerClientManager,
MessageSender delegate) |
| 构造器和说明 |
|---|
TxFeedbackManagerWrapper(ClusterManager clusterManager,
ProducerClientManager producerClientManager,
MessageSender messageSender,
TxFeedbackManager delegate) |
| 构造器和说明 |
|---|
DefaultMessageProducer(ProducerConfig config,
NameServerConfig nameServerConfig,
ClusterManager clusterManager,
ProducerClientManager producerClientManager) |
DefaultMessageSender(ProducerClientManager producerClientManager,
SenderConfig config) |
MessageProducerInner(ProducerConfig config,
NameServerConfig nameServerConfig,
MessageSender messageSender,
ClusterManager clusterManager,
ProducerClientManager producerClientManager) |
MessageProducerInner(ProducerConfig config,
NameServerConfig nameServerConfig,
MessageSender messageSender,
ClusterManager clusterManager,
ProducerClientManager producerClientManager,
ProducerInterceptorManager producerInterceptorManager) |
MessageProducerWrapper(ClusterManager clusterManager,
ProducerClientManager producerClientManager,
MessageProducer delegate) |
| 限定符和类型 | 方法和说明 |
|---|---|
static ProducerClientManager |
ProducerClientManagerFactory.create(NameServerConfig nameServerConfig) |
static ProducerClientManager |
ProducerClientManagerFactory.create(NameServerConfig nameServerConfig,
TransportConfig transportConfig) |
static ProducerClientManager |
ProducerClientManagerFactory.create(String address,
String app,
String token) |
static ProducerClientManager |
ProducerClientManagerFactory.create(String address,
String app,
String token,
String region,
String namespace) |
| 限定符和类型 | 方法和说明 |
|---|---|
protected ProducerClientManager |
DefaultMessageAccessPoint.getProducerClientManager() |
Copyright © 2020 Joyqueue Community. All rights reserved.