类的使用
org.joyqueue.client.internal.cluster.ClusterManager

使用ClusterManager的程序包

程序包	说明
org.joyqueue.client.internal.cluster
org.joyqueue.client.internal.consumer
org.joyqueue.client.internal.consumer.container
org.joyqueue.client.internal.consumer.support
org.joyqueue.client.internal.producer
org.joyqueue.client.internal.producer.feedback
org.joyqueue.client.internal.producer.support
org.joyqueue.client.internal.support

org.joyqueue.client.internal.cluster中ClusterManager的使用

org.joyqueue.client.internal.cluster中ClusterManager的子类

限定符和类型	类和说明
class	ClusterManagerWrapper ClusterManagerWrapper author: gaohaoxiang date: 2018/12/27

返回ClusterManager的org.joyqueue.client.internal.cluster中的方法

限定符和类型	方法和说明
static ClusterManager	ClusterManagerFactory.create(NameServerConfig nameServerConfig)
static ClusterManager	ClusterManagerFactory.create(NameServerConfig nameServerConfig, ClusterClientManager clusterClientManager)
static ClusterManager	ClusterManagerFactory.create(NameServerConfig nameServerConfig, TransportConfig transportConfig)
static ClusterManager	ClusterManagerFactory.create(String address, String app, String token)
static ClusterManager	ClusterManagerFactory.create(String address, String app, String token, String region, String namespace)

org.joyqueue.client.internal.consumer中ClusterManager的使用

参数类型为ClusterManager的org.joyqueue.client.internal.consumer中的方法

限定符和类型	方法和说明
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 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)

org.joyqueue.client.internal.consumer.container中ClusterManager的使用

参数类型为ClusterManager的org.joyqueue.client.internal.consumer.container中的方法

限定符和类型	方法和说明
static MessageListenerContainer	MessageListenerContainerFactory.create(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, ClusterManager clusterManager, ClusterClientManager clusterClientManager, ConsumerClientManager consumerClientManager) 已过时。

参数类型为ClusterManager的org.joyqueue.client.internal.consumer.container中的构造器

构造器和说明
DefaultMessageListenerContainer(ConsumerConfig config, NameServerConfig nameServerConfig, ClusterManager clusterManager, ClusterClientManager clusterClientManager, ConsumerClientManager consumerClientManager)
MessageListenerContainerWrapper(ConsumerConfig config, NameServerConfig nameServerConfig, ClusterManager clusterManager, ClusterClientManager clusterClientManager, ConsumerClientManager consumerClientManager, MessageListenerContainer delegate)

org.joyqueue.client.internal.consumer.support中ClusterManager的使用

参数类型为ClusterManager的org.joyqueue.client.internal.consumer.support中的构造器

构造器和说明
BroadcastMessagePoller(ConsumerConfig config, NameServerConfig nameServerConfig, ClusterManager clusterManager, ConsumerClientManager consumerClientManager)
DefaultConsumerIndexManager(ClusterManager clusterManager, ConsumerClientManager consumerClientManager)
DefaultMessageConsumer(ConsumerConfig config, NameServerConfig nameServerConfig, ClusterManager clusterManager, ClusterClientManager clusterClientManager, ConsumerClientManager consumerClientManager)
DefaultMessagePoller(ConsumerConfig config, NameServerConfig nameServerConfig, ClusterManager clusterManager, ClusterClientManager clusterClientManager, ConsumerClientManager consumerClientManager)
MessageConsumerWrapper(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, ClusterManager clusterManager, ClusterClientManager clusterClientManager, ConsumerClientManager consumerClientManager, MessageConsumer delegate)
MessagePollerInner(ConsumerConfig config, NameServerConfig nameServerConfig, ClusterManager clusterManager, ConsumerClientManager consumerClientManager, MessageFetcher messageFetcher)
MessagePollerWrapper(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, ClusterManager clusterManager, ClusterClientManager clusterClientManager, ConsumerClientManager consumerClientManager, MessagePoller delegate)
PartitionMessagePoller(ConsumerConfig config, NameServerConfig nameServerConfig, ClusterManager clusterManager, ConsumerClientManager consumerClientManager, ConsumerIndexManager consumerIndexManager)
TopicMessageConsumer(String topic, ConsumerConfig config, NameServerConfig nameServerConfig, ClusterManager clusterManager, ClusterClientManager clusterClientManager, ConsumerClientManager consumerClientManager)
TopicMessageConsumer(String topic, ConsumerConfig config, NameServerConfig nameServerConfig, ClusterManager clusterManager, ClusterClientManager clusterClientManager, ConsumerClientManager consumerClientManager, ConsumerInterceptorManager consumerInterceptorManager)

org.joyqueue.client.internal.producer中ClusterManager的使用

参数类型为ClusterManager的org.joyqueue.client.internal.producer中的方法

限定符和类型	方法和说明
static MessageProducer	MessageProducerFactory.create(ProducerConfig producerConfig, NameServerConfig nameServerConfig, ClusterManager clusterManager, ProducerClientManager producerClientManager)
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, ClusterManager clusterManager)

org.joyqueue.client.internal.producer.feedback中ClusterManager的使用

参数类型为ClusterManager的org.joyqueue.client.internal.producer.feedback中的构造器

构造器和说明
DefaultTxFeedbackManager(TxFeedbackConfig config, NameServerConfig nameServerConfig, ClusterManager clusterManager, MessageSender messageSender)
TxFeedbackDispatcher(TxFeedbackConfig config, String topic, TxFeedbackCallback txFeedbackCallback, MessageSender messageSender, ClusterManager clusterManager)
TxFeedbackManagerWrapper(ClusterManager clusterManager, ProducerClientManager producerClientManager, MessageSender messageSender, TxFeedbackManager delegate)
TxFeedbackScheduler(TxFeedbackConfig config, String topic, TxFeedbackCallback txFeedbackCallback, MessageSender messageSender, ClusterManager clusterManager)

org.joyqueue.client.internal.producer.support中ClusterManager的使用

参数类型为ClusterManager的org.joyqueue.client.internal.producer.support中的构造器

构造器和说明
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)
MessageProducerWrapper(ClusterManager clusterManager, ProducerClientManager producerClientManager, MessageProducer delegate)

org.joyqueue.client.internal.support中ClusterManager的使用

返回ClusterManager的org.joyqueue.client.internal.support中的方法

限定符和类型	方法和说明
protected ClusterManager	DefaultMessageAccessPoint.getClusterManager()