类的使用
org.joyqueue.client.internal.consumer.transport.ConsumerClientManager

使用ConsumerClientManager的程序包

程序包	说明
org.joyqueue.client.internal.consumer
org.joyqueue.client.internal.consumer.container
org.joyqueue.client.internal.consumer.support
org.joyqueue.client.internal.consumer.transport
org.joyqueue.client.internal.support

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

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

限定符和类型	方法和说明
static MessageFetcher	MessageFetcherFactory.create(ConsumerClientManager consumerClientManager, FetcherConfig config)
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, ConsumerClientManager consumerClientManager)
static MessagePoller	MessagePollerFactory.create(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, TransportConfig transportConfig, 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中ConsumerClientManager的使用

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

限定符和类型	方法和说明
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, ConsumerClientManager consumerClientManager) 已过时。

参数类型为ConsumerClientManager的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中ConsumerClientManager的使用

参数类型为ConsumerClientManager的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)
DefaultMessageFetcher(ConsumerClientManager consumerClientManager, FetcherConfig config)
DefaultMessagePoller(ConsumerConfig config, NameServerConfig nameServerConfig, ClusterManager clusterManager, ClusterClientManager clusterClientManager, ConsumerClientManager consumerClientManager)
MessageConsumerWrapper(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, ClusterManager clusterManager, ClusterClientManager clusterClientManager, ConsumerClientManager consumerClientManager, MessageConsumer delegate)
MessageFetcherWrapper(ConsumerClientManager consumerClientManager, MessageFetcher 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.consumer.transport中ConsumerClientManager的使用

返回ConsumerClientManager的org.joyqueue.client.internal.consumer.transport中的方法

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

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

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

限定符和类型	方法和说明
protected ConsumerClientManager	DefaultMessageAccessPoint.getConsumerClientManager()