| 限定符和类型 | 方法和说明 |
|---|---|
static ClusterClientManager |
ClusterClientManagerFactory.create(NameServerConfig nameServerConfig) |
static ClusterClientManager |
ClusterClientManagerFactory.create(NameServerConfig nameServerConfig,
TransportConfig transportConfig) |
static ClusterClientManager |
ClusterClientManagerFactory.create(String address,
String app,
String token) |
static ClusterClientManager |
ClusterClientManagerFactory.create(String address,
String app,
String token,
String region,
String namespace) |
| 限定符和类型 | 方法和说明 |
|---|---|
static ClusterManager |
ClusterManagerFactory.create(NameServerConfig nameServerConfig,
ClusterClientManager clusterClientManager) |
| 构造器和说明 |
|---|
ClusterManager(NameServerConfig config,
ClusterClientManager clusterClientManager) |
ClusterManagerWrapper(NameServerConfig nameServerConfig,
ClusterClientManager clusterClientManager) |
| 限定符和类型 | 方法和说明 |
|---|---|
static MessageConsumer |
MessageConsumerFactory.create(ConsumerConfig consumerConfig,
NameServerConfig nameServerConfig,
ClusterClientManager clusterClientManager,
ConsumerClientManager consumerClientManager) |
static MessagePoller |
MessagePollerFactory.create(ConsumerConfig consumerConfig,
NameServerConfig nameServerConfig,
ClusterClientManager clusterClientManager,
ConsumerClientManager consumerClientManager) |
static MessageConsumer |
MessageConsumerFactory.create(ConsumerConfig consumerConfig,
NameServerConfig nameServerConfig,
ClusterManager clusterManager,
ClusterClientManager clusterClientManager,
ConsumerClientManager consumerClientManager) |
static MessagePoller |
MessagePollerFactory.create(ConsumerConfig consumerConfig,
NameServerConfig nameServerConfig,
ClusterManager clusterManager,
ClusterClientManager clusterClientManager,
ConsumerClientManager consumerClientManager) |
| 限定符和类型 | 方法和说明 |
|---|---|
static MessageListenerContainer |
MessageListenerContainerFactory.create(ConsumerConfig consumerConfig,
NameServerConfig nameServerConfig,
ClusterClientManager clusterClientManager,
ConsumerClientManager consumerClientManager)
已过时。
|
static MessageListenerContainer |
MessageListenerContainerFactory.create(ConsumerConfig consumerConfig,
NameServerConfig nameServerConfig,
ClusterManager clusterManager,
ClusterClientManager clusterClientManager,
ConsumerClientManager consumerClientManager)
已过时。
|
| 构造器和说明 |
|---|
DefaultMessageListenerContainer(ConsumerConfig config,
NameServerConfig nameServerConfig,
ClusterManager clusterManager,
ClusterClientManager clusterClientManager,
ConsumerClientManager consumerClientManager) |
MessageListenerContainerWrapper(ConsumerConfig config,
NameServerConfig nameServerConfig,
ClusterManager clusterManager,
ClusterClientManager clusterClientManager,
ConsumerClientManager consumerClientManager,
MessageListenerContainer delegate) |
| 构造器和说明 |
|---|
ConsumerCoordinator(ClusterClientManager clusterClientManager) |
CoordinatorManager(ClusterClientManager clusterClientManager) |
PartitionAssignmentManager(ClusterClientManager clusterClientManager,
CoordinatorManager coordinatorManager) |
| 构造器和说明 |
|---|
MetadataManager(ClusterClientManager clusterClientManager) |
| 限定符和类型 | 方法和说明 |
|---|---|
static MessageProducer |
MessageProducerFactory.create(ProducerConfig producerConfig,
NameServerConfig nameServerConfig,
ClusterClientManager clusterClientManager,
ProducerClientManager producerClientManager) |
| 限定符和类型 | 方法和说明 |
|---|---|
protected ClusterClientManager |
DefaultMessageAccessPoint.getClusterClientManager() |
Copyright © 2020 Joyqueue Community. All rights reserved.