| 限定符和类型 | 方法和说明 |
|---|---|
static NameServerConfig |
KeyValueConverter.convertNameServerConfig(io.openmessaging.KeyValue attributes) |
| 限定符和类型 | 方法和说明 |
|---|---|
static ConsumerConfig |
KeyValueConverter.convertConsumerConfig(NameServerConfig nameServerConfig,
io.openmessaging.KeyValue attributes) |
static TxFeedbackConfig |
KeyValueConverter.convertFeedbackConfig(NameServerConfig nameServerConfig,
io.openmessaging.KeyValue attributes) |
static ProducerConfig |
KeyValueConverter.convertProducerConfig(NameServerConfig nameServerConfig,
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) |
static ClusterManager |
ClusterManagerFactory.create(NameServerConfig nameServerConfig) |
static ClusterManager |
ClusterManagerFactory.create(NameServerConfig nameServerConfig,
ClusterClientManager clusterClientManager) |
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) |
ClusterManager(NameServerConfig config,
ClusterClientManager clusterClientManager) |
ClusterManagerWrapper(NameServerConfig nameServerConfig,
ClusterClientManager clusterClientManager) |
MetadataCacheManager(NameServerConfig config) |
MetadataUpdater(NameServerConfig config,
MetadataManager metadataManager,
MetadataCacheManager metadataCacheManager) |
| 限定符和类型 | 方法和说明 |
|---|---|
static MessageConsumer |
MessageConsumerFactory.create(ConsumerConfig consumerConfig,
NameServerConfig nameServerConfig) |
static MessagePoller |
MessagePollerFactory.create(ConsumerConfig consumerConfig,
NameServerConfig nameServerConfig) |
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 MessageConsumer |
MessageConsumerFactory.create(ConsumerConfig consumerConfig,
NameServerConfig nameServerConfig,
ConsumerClientManager consumerClientManager) |
static MessagePoller |
MessagePollerFactory.create(ConsumerConfig consumerConfig,
NameServerConfig nameServerConfig,
ConsumerClientManager consumerClientManager) |
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(NameServerConfig nameServerConfig) |
static MessageFetcher |
MessageFetcherFactory.create(NameServerConfig nameServerConfig,
FetcherConfig config) |
static MessageFetcher |
MessageFetcherFactory.create(TransportConfig transportConfig,
NameServerConfig nameServerConfig,
FetcherConfig config) |
static MessagePoller |
MessagePollerFactory.createBroadcastPoller(ConsumerConfig consumerConfig,
NameServerConfig nameServerConfig,
ClusterManager clusterManager,
ConsumerClientManager consumerClientManager) |
static MessagePoller |
MessagePollerFactory.createPartitionPoller(ConsumerConfig consumerConfig,
NameServerConfig nameServerConfig,
ClusterManager clusterManager,
ConsumerClientManager consumerClientManager,
ConsumerIndexManager consumerIndexManager) |
| 限定符和类型 | 方法和说明 |
|---|---|
static MessageListenerContainer |
MessageListenerContainerFactory.create(ConsumerConfig consumerConfig,
NameServerConfig nameServerConfig)
已过时。
|
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)
已过时。
|
static MessageListenerContainer |
MessageListenerContainerFactory.create(ConsumerConfig consumerConfig,
NameServerConfig nameServerConfig,
ConsumerClientManager consumerClientManager)
已过时。
|
static MessageListenerContainer |
MessageListenerContainerFactory.create(ConsumerConfig consumerConfig,
NameServerConfig nameServerConfig,
TransportConfig transportConfig)
已过时。
|
static MessageListenerContainer |
MessageListenerContainerFactory.create(ConsumerConfig consumerConfig,
NameServerConfig nameServerConfig,
TransportConfig transportConfig,
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) |
| 限定符和类型 | 方法和说明 |
|---|---|
NameServerConfig |
ConsumeContext.getNameserver() |
| 构造器和说明 |
|---|
ConsumeContext(String topic,
String app,
NameServerConfig nameserver,
List<ConsumeMessage> messages) |
ConsumerInvocation(ConsumerConfig config,
String topic,
NameServerConfig nameServerConfig,
List<ConsumeMessage> messages,
ConsumerInterceptorManager consumerInterceptorManager,
ConsumerInvoker consumerInvoker) |
| 限定符和类型 | 方法和说明 |
|---|---|
static ConsumerClientManager |
ConsumerClientManagerFactory.create(NameServerConfig nameServerConfig) |
static ConsumerClientManager |
ConsumerClientManagerFactory.create(NameServerConfig nameServerConfig,
TransportConfig transportConfig) |
| 构造器和说明 |
|---|
ConsumerClientManager(TransportConfig transportConfig,
NameServerConfig nameServerConfig) |
| 限定符和类型 | 方法和说明 |
|---|---|
static void |
NameServerConfigChecker.check(NameServerConfig config) |
| 限定符和类型 | 方法和说明 |
|---|---|
static NameServerConfig |
NameServerHelper.createConfig(String address,
String app,
String token) |
static NameServerConfig |
NameServerHelper.createConfig(String address,
String app,
String token,
String region,
String namespace) |
| 限定符和类型 | 方法和说明 |
|---|---|
static String |
NameServerHelper.getTopicFullName(String topic,
NameServerConfig config) |
| 限定符和类型 | 方法和说明 |
|---|---|
static MessageSender |
MessageSenderFactory.create(NameServerConfig nameServerConfig) |
static MessageSender |
MessageSenderFactory.create(NameServerConfig nameServerConfig,
SenderConfig config) |
static MessageSender |
MessageSenderFactory.create(NameServerConfig nameServerConfig,
TransportConfig transportConfig,
SenderConfig 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 TxFeedbackManager |
TxFeedbackManagerFactory.create(TxFeedbackConfig config,
NameServerConfig nameServerConfig) |
static TxFeedbackManager |
TxFeedbackManagerFactory.create(TxFeedbackConfig config,
NameServerConfig nameServerConfig,
ClusterManager clusterManager) |
static TxFeedbackManager |
TxFeedbackManagerFactory.create(TxFeedbackConfig config,
NameServerConfig nameServerConfig,
ClusterManager clusterManager,
ProducerClientManager producerClientManager) |
static TxFeedbackManager |
TxFeedbackManagerFactory.create(TxFeedbackConfig config,
NameServerConfig nameServerConfig,
TransportConfig transportConfig) |
static TxFeedbackManager |
TxFeedbackManagerFactory.create(TxFeedbackConfig config,
NameServerConfig nameServerConfig,
TransportConfig transportConfig,
ClusterManager clusterManager) |
| 构造器和说明 |
|---|
DefaultTxFeedbackManager(TxFeedbackConfig config,
NameServerConfig nameServerConfig,
ClusterManager clusterManager,
MessageSender messageSender) |
| 限定符和类型 | 方法和说明 |
|---|---|
NameServerConfig |
ProduceContext.getNameserver() |
| 构造器和说明 |
|---|
ProduceContext(String topic,
String app,
NameServerConfig nameserver,
List<ProduceMessage> messages) |
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) |
| 限定符和类型 | 方法和说明 |
|---|---|
static ProducerClientManager |
ProducerClientManagerFactory.create(NameServerConfig nameServerConfig) |
static ProducerClientManager |
ProducerClientManagerFactory.create(NameServerConfig nameServerConfig,
TransportConfig transportConfig) |
| 构造器和说明 |
|---|
ProducerClientManager(TransportConfig transportConfig,
NameServerConfig nameServerConfig) |
| 构造器和说明 |
|---|
DefaultMessageAccessPoint(NameServerConfig nameServerConfig,
TransportConfig transportConfig) |
| 构造器和说明 |
|---|
Client(BrokerNode node,
TransportConfig transportConfig,
TransportClient transportClient,
NameServerConfig nameServerConfig) |
ClientConnectionState(NameServerConfig nameServerConfig,
Client client) |
ClientGroup(BrokerNode node,
TransportConfig transportConfig,
TransportClient transportClient,
NameServerConfig nameServerConfig) |
ClientManager(TransportConfig transportConfig,
NameServerConfig nameServerConfig) |
Copyright © 2020 Joyqueue Community. All rights reserved.