| 限定符和类型 | 方法和说明 |
|---|---|
static TransportConfig |
KeyValueConverter.convertTransportConfig(io.openmessaging.KeyValue attributes) |
| 限定符和类型 | 方法和说明 |
|---|---|
static MessageAccessPoint |
MessageAccessPointFactory.create(NameServerConfig nameServerConfig,
TransportConfig transportConfig) |
| 限定符和类型 | 方法和说明 |
|---|---|
static ClusterClient |
ClusterClient.build(Client client,
TransportConfig transportConfig,
NameServerConfig nameServerConfig) |
static ClusterClientManager |
ClusterClientManagerFactory.create(NameServerConfig nameServerConfig,
TransportConfig transportConfig) |
static ClusterManager |
ClusterManagerFactory.create(NameServerConfig nameServerConfig,
TransportConfig transportConfig) |
| 构造器和说明 |
|---|
ClusterClient(Client client,
TransportConfig transportConfig,
NameServerConfig nameServerConfig) |
ClusterClientManager(TransportConfig transportConfig,
NameServerConfig nameServerConfig) |
| 限定符和类型 | 方法和说明 |
|---|---|
static MessageConsumer |
MessageConsumerFactory.create(ConsumerConfig consumerConfig,
NameServerConfig nameServerConfig,
TransportConfig transportConfig) |
static MessagePoller |
MessagePollerFactory.create(ConsumerConfig consumerConfig,
NameServerConfig nameServerConfig,
TransportConfig transportConfig) |
static MessageConsumer |
MessageConsumerFactory.create(ConsumerConfig consumerConfig,
NameServerConfig nameServerConfig,
TransportConfig transportConfig,
ConsumerClientManager consumerClientManager) |
static MessagePoller |
MessagePollerFactory.create(ConsumerConfig consumerConfig,
NameServerConfig nameServerConfig,
TransportConfig transportConfig,
ConsumerClientManager consumerClientManager) |
static MessageFetcher |
MessageFetcherFactory.create(TransportConfig transportConfig,
NameServerConfig nameServerConfig,
FetcherConfig config) |
| 限定符和类型 | 方法和说明 |
|---|---|
static MessageListenerContainer |
MessageListenerContainerFactory.create(ConsumerConfig consumerConfig,
NameServerConfig nameServerConfig,
TransportConfig transportConfig)
已过时。
|
static MessageListenerContainer |
MessageListenerContainerFactory.create(ConsumerConfig consumerConfig,
NameServerConfig nameServerConfig,
TransportConfig transportConfig,
ConsumerClientManager consumerClientManager)
已过时。
|
| 限定符和类型 | 方法和说明 |
|---|---|
static ConsumerClientManager |
ConsumerClientManagerFactory.create(NameServerConfig nameServerConfig,
TransportConfig transportConfig) |
| 构造器和说明 |
|---|
ConsumerClientManager(TransportConfig transportConfig,
NameServerConfig nameServerConfig) |
| 限定符和类型 | 方法和说明 |
|---|---|
static MessageSender |
MessageSenderFactory.create(NameServerConfig nameServerConfig,
TransportConfig transportConfig,
SenderConfig config) |
static MessageProducer |
MessageProducerFactory.create(ProducerConfig producerConfig,
NameServerConfig nameServerConfig,
TransportConfig transportConfig) |
static MessageProducer |
MessageProducerFactory.create(ProducerConfig producerConfig,
NameServerConfig nameServerConfig,
TransportConfig transportConfig,
ProducerClientManager producerClientManager) |
static TxFeedbackManager |
TxFeedbackManagerFactory.create(TxFeedbackConfig config,
NameServerConfig nameServerConfig,
TransportConfig transportConfig) |
static TxFeedbackManager |
TxFeedbackManagerFactory.create(TxFeedbackConfig config,
NameServerConfig nameServerConfig,
TransportConfig transportConfig,
ClusterManager clusterManager) |
| 限定符和类型 | 方法和说明 |
|---|---|
static ProducerClientManager |
ProducerClientManagerFactory.create(NameServerConfig nameServerConfig,
TransportConfig transportConfig) |
| 构造器和说明 |
|---|
ProducerClientManager(TransportConfig transportConfig,
NameServerConfig nameServerConfig) |
| 构造器和说明 |
|---|
DefaultMessageAccessPoint(NameServerConfig nameServerConfig,
TransportConfig transportConfig) |
| 限定符和类型 | 方法和说明 |
|---|---|
protected ClientConfig |
ClientManager.convertToClientConfig(TransportConfig transportConfig) |
protected Client |
ClientGroup.initClient(BrokerNode node,
TransportConfig transportConfig,
TransportClient transportClient) |
| 构造器和说明 |
|---|
Client(BrokerNode node,
TransportConfig transportConfig,
TransportClient transportClient,
NameServerConfig nameServerConfig) |
ClientGroup(BrokerNode node,
TransportConfig transportConfig,
TransportClient transportClient,
NameServerConfig nameServerConfig) |
ClientGroupManager(TransportConfig config) |
ClientHeartbeatThread(TransportConfig transportConfig,
ClientGroupManager clientGroupManager) |
ClientManager(TransportConfig transportConfig,
NameServerConfig nameServerConfig) |
| 限定符和类型 | 方法和说明 |
|---|---|
TransportConfig |
TransportConfig.copy() |
| 限定符和类型 | 方法和说明 |
|---|---|
static void |
TransportConfigChecker.check(TransportConfig config) |
Copyright © 2020 Joyqueue Community. All rights reserved.