接口的使用
org.joyqueue.client.internal.consumer.MessagePoller

使用MessagePoller的程序包

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

org.joyqueue.client.internal中MessagePoller的使用

返回MessagePoller的org.joyqueue.client.internal中的方法

限定符和类型	方法和说明
MessagePoller	MessageAccessPoint.createPoller()
MessagePoller	MessageAccessPoint.createPoller(ConsumerConfig config)
MessagePoller	MessageAccessPoint.createPoller(String group)

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

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

限定符和类型	方法和说明
static MessagePoller	MessagePollerFactory.create(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig)
static MessagePoller	MessagePollerFactory.create(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, ClusterClientManager clusterClientManager, ConsumerClientManager consumerClientManager)
static MessagePoller	MessagePollerFactory.create(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, ClusterManager clusterManager, ClusterClientManager clusterClientManager, ConsumerClientManager consumerClientManager)
static MessagePoller	MessagePollerFactory.create(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, ConsumerClientManager consumerClientManager)
static MessagePoller	MessagePollerFactory.create(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, TransportConfig transportConfig)
static MessagePoller	MessagePollerFactory.create(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, TransportConfig transportConfig, ConsumerClientManager consumerClientManager)
static MessagePoller	MessagePollerFactory.create(String address, String app, String token)
static MessagePoller	MessagePollerFactory.create(String address, String app, String token, String region)
static MessagePoller	MessagePollerFactory.create(String address, String app, String token, String region, String namespace)
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.support中MessagePoller的使用

实现MessagePoller的org.joyqueue.client.internal.consumer.support中的类

限定符和类型	类和说明
class	BroadcastMessagePoller BroadcastMessagePoller author: gaohaoxiang date: 2018/12/14
class	DefaultMessagePoller DefaultMessagePoller author: gaohaoxiang date: 2018/12/11
class	MessagePollerWrapper MessagePollerWrapper author: gaohaoxiang date: 2018/12/27
class	PartitionMessagePoller PartitionMessagePoller author: gaohaoxiang date: 2018/12/14

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

限定符和类型	方法和说明
protected MessagePoller	TopicMessageConsumer.createMessageConsumer(String topic)
MessagePoller	TopicMessageConsumer.getMessagePoller()

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

构造器和说明
MessagePollerWrapper(ConsumerConfig consumerConfig, NameServerConfig nameServerConfig, ClusterManager clusterManager, ClusterClientManager clusterClientManager, ConsumerClientManager consumerClientManager, MessagePoller delegate)
TopicMessageConsumerDispatcher(String topic, ConsumerConfig config, NameServerConfig nameServerConfig, MessagePoller messagePoller, MessageListenerManager messageListenerManager, ConsumerInterceptorManager consumerInterceptorManager)
TopicMessageConsumerScheduler(String topic, ConsumerConfig config, MessagePoller messagePoller, TopicMessageConsumerDispatcher messageConsumerDispatcher)

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

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

限定符和类型	方法和说明
MessagePoller	DefaultMessageAccessPoint.createPoller()
MessagePoller	DefaultMessageAccessPoint.createPoller(ConsumerConfig config)
MessagePoller	DefaultMessageAccessPoint.createPoller(String group)