接口的使用
org.joyqueue.client.internal.consumer.callback.PollerListener

使用PollerListener的程序包

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

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

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

限定符和类型	类和说明
class	CompletableFuturePollerListener CompletableFuturePollerListener author: gaohaoxiang date: 2019/7/25

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

限定符和类型	方法和说明
List<ConsumeMessage>	MessagePollerInner.buildPollEmptyResult(PollerListener listener)
protected List<ConsumeMessage>	MessagePollerInner.doFetchPartition(BrokerNode brokerNode, TopicMetadata topicMetadata, short partition, long index, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
protected List<ConsumeMessage>	MessagePollerInner.doFetchTopic(BrokerNode brokerNode, TopicMetadata topicMetadata, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
protected List<ConsumeMessage>	DefaultMessagePoller.doPoll(String topic, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
protected List<ConsumeMessage>	PartitionMessagePoller.doPoll(String topic, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
protected List<ConsumeMessage>	DefaultMessagePoller.doPollPartition(String topic, short partition, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
protected List<ConsumeMessage>	PartitionMessagePoller.doPollPartition(String topic, short partition, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
protected List<ConsumeMessage>	DefaultMessagePoller.doPollPartition(String topic, short partition, long index, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
protected List<ConsumeMessage>	PartitionMessagePoller.doPollPartition(String topic, short partition, long index, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
protected List<ConsumeMessage>	PartitionMessagePoller.doPollPartitionInternal(BrokerNode brokerNode, String topic, short partition, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
protected List<ConsumeMessage>	PartitionMessagePoller.doPollPartitionInternal(BrokerNode brokerNode, String topic, short partition, long index, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
List<ConsumeMessage>	MessagePollerInner.fetchPartition(BrokerNode brokerNode, String topic, short partition, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
List<ConsumeMessage>	MessagePollerInner.fetchPartition(BrokerNode brokerNode, String topic, short partition, long index, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
List<ConsumeMessage>	MessagePollerInner.fetchPartition(BrokerNode brokerNode, TopicMetadata topicMetadata, short partition, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
List<ConsumeMessage>	MessagePollerInner.fetchPartition(BrokerNode brokerNode, TopicMetadata topicMetadata, short partition, long index, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
List<ConsumeMessage>	MessagePollerInner.fetchTopic(BrokerNode brokerNode, String topic, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
List<ConsumeMessage>	MessagePollerInner.fetchTopic(BrokerNode brokerNode, TopicMetadata topicMetadata, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)