org.joyqueue.client.internal.consumer

接口 MessagePoller

所有超级接口:

LifeCycle, Online

所有已知实现类:

BroadcastMessagePoller, DefaultMessagePoller, MessagePollerWrapper, PartitionMessagePoller

public interface MessagePoller
extends LifeCycle

MessagePoller author: gaohaoxiang date: 2018/12/11

方法概要

限定符和类型	方法和说明
FetchIndexData	fetchIndex(String topic, short partition)
TopicMetadata	getTopicMetadata(String topic)
List<ConsumeMessage>	poll(String topic)
List<ConsumeMessage>	poll(String topic, long timeout, TimeUnit timeoutUnit)
CompletableFuture<List<ConsumeMessage>>	pollAsync(String topic)
CompletableFuture<List<ConsumeMessage>>	pollAsync(String topic, long timeout, TimeUnit timeoutUnit)
ConsumeMessage	pollOnce(String topic)
ConsumeMessage	pollOnce(String topic, long timeout, TimeUnit timeoutUnit)
List<ConsumeMessage>	pollPartition(String topic, short partition)
List<ConsumeMessage>	pollPartition(String topic, short partition, long index)
List<ConsumeMessage>	pollPartition(String topic, short partition, long index, long timeout, TimeUnit timeoutUnit)
List<ConsumeMessage>	pollPartition(String topic, short partition, long timeout, TimeUnit timeoutUnit)
CompletableFuture<List<ConsumeMessage>>	pollPartitionAsync(String topic, short partition)
CompletableFuture<List<ConsumeMessage>>	pollPartitionAsync(String topic, short partition, long index)
CompletableFuture<List<ConsumeMessage>>	pollPartitionAsync(String topic, short partition, long index, long timeout, TimeUnit timeoutUnit)
CompletableFuture<List<ConsumeMessage>>	pollPartitionAsync(String topic, short partition, long timeout, TimeUnit timeoutUnit)
ConsumeMessage	pollPartitionOnce(String topic, short partition)
ConsumeMessage	pollPartitionOnce(String topic, short partition, long index)
ConsumeMessage	pollPartitionOnce(String topic, short partition, long index, long timeout, TimeUnit timeoutUnit)
ConsumeMessage	pollPartitionOnce(String topic, short partition, long timeout, TimeUnit timeoutUnit)
org.joyqueue.exception.JoyQueueCode	reply(String topic, List<ConsumeReply> replyList)
org.joyqueue.exception.JoyQueueCode	replyOnce(String topic, ConsumeReply reply)

从接口继承的方法 org.joyqueue.toolkit.lang.LifeCycle

start, stop

从接口继承的方法 org.joyqueue.toolkit.lang.Online

isStarted

方法详细资料

pollOnce

ConsumeMessage pollOnce(String topic)

pollOnce

ConsumeMessage pollOnce(String topic,
                        long timeout,
                        TimeUnit timeoutUnit)

poll

List<ConsumeMessage> poll(String topic)

poll

List<ConsumeMessage> poll(String topic,
                          long timeout,
                          TimeUnit timeoutUnit)

pollAsync

CompletableFuture<List<ConsumeMessage>> pollAsync(String topic)

pollAsync

CompletableFuture<List<ConsumeMessage>> pollAsync(String topic,
                                                  long timeout,
                                                  TimeUnit timeoutUnit)

pollPartitionOnce

ConsumeMessage pollPartitionOnce(String topic,
                                 short partition)

pollPartitionOnce

ConsumeMessage pollPartitionOnce(String topic,
                                 short partition,
                                 long timeout,
                                 TimeUnit timeoutUnit)

pollPartitionOnce

ConsumeMessage pollPartitionOnce(String topic,
                                 short partition,
                                 long index)

pollPartitionOnce

ConsumeMessage pollPartitionOnce(String topic,
                                 short partition,
                                 long index,
                                 long timeout,
                                 TimeUnit timeoutUnit)

pollPartition

List<ConsumeMessage> pollPartition(String topic,
                                   short partition)

pollPartition

List<ConsumeMessage> pollPartition(String topic,
                                   short partition,
                                   long timeout,
                                   TimeUnit timeoutUnit)

pollPartition

List<ConsumeMessage> pollPartition(String topic,
                                   short partition,
                                   long index)

pollPartition

List<ConsumeMessage> pollPartition(String topic,
                                   short partition,
                                   long index,
                                   long timeout,
                                   TimeUnit timeoutUnit)

pollPartitionAsync

CompletableFuture<List<ConsumeMessage>> pollPartitionAsync(String topic,
                                                           short partition)

pollPartitionAsync

CompletableFuture<List<ConsumeMessage>> pollPartitionAsync(String topic,
                                                           short partition,
                                                           long timeout,
                                                           TimeUnit timeoutUnit)

pollPartitionAsync

CompletableFuture<List<ConsumeMessage>> pollPartitionAsync(String topic,
                                                           short partition,
                                                           long index)

pollPartitionAsync

CompletableFuture<List<ConsumeMessage>> pollPartitionAsync(String topic,
                                                           short partition,
                                                           long index,
                                                           long timeout,
                                                           TimeUnit timeoutUnit)

reply

org.joyqueue.exception.JoyQueueCode reply(String topic,
                                          List<ConsumeReply> replyList)

replyOnce

org.joyqueue.exception.JoyQueueCode replyOnce(String topic,
                                              ConsumeReply reply)

fetchIndex

FetchIndexData fetchIndex(String topic,
                          short partition)

getTopicMetadata

TopicMetadata getTopicMetadata(String topic)