org.joyqueue.client.internal.consumer

接口 MessageFetcher

所有超级接口:

LifeCycle, Online

所有已知实现类:

DefaultMessageFetcher, MessageFetcherWrapper

public interface MessageFetcher
extends LifeCycle

MessageFetcher author: gaohaoxiang date: 2018/12/7

方法概要

限定符和类型	方法和说明
void	asyncFetch(BrokerNode brokerNode, String topic, String app, int count, long timeout, long ackTimeout, long longPollTimeout, FetchListener listener)
Map<String,FetchMessageData>	batchFetch(BrokerNode brokerNode, List<String> topics, String app, int count, long timeout, long ackTimeout, long longPollTimeout)
void	batchFetchAsync(BrokerNode brokerNode, List<String> topics, String app, int count, long timeout, long ackTimeout, long longPollTimeout, BatchFetchListener listener)
com.google.common.collect.Table<String,Short,FetchMessageData>	batchFetchPartitions(BrokerNode brokerNode, Map<String,Short> partitions, String app, int count, long timeout)
com.google.common.collect.Table<String,Short,FetchMessageData>	batchFetchPartitions(BrokerNode brokerNode, com.google.common.collect.Table<String,Short,Long> partitions, String app, int count, long timeout)
void	batchFetchPartitionsAsync(BrokerNode brokerNode, Map<String,Short> partitions, String app, int count, long timeout, BatchPartitionFetchListener listener)
void	batchFetchPartitionsAsync(BrokerNode brokerNode, com.google.common.collect.Table<String,Short,Long> partitions, String app, int count, long timeout, BatchPartitionFetchListener listener)
FetchMessageData	fetch(BrokerNode brokerNode, String topic, String app, int count, long timeout, long ackTimeout, long longPollTimeout)
FetchMessageData	fetchPartition(BrokerNode brokerNode, String topic, String app, short partition, int count, long timeout)
FetchMessageData	fetchPartition(BrokerNode brokerNode, String topic, String app, short partition, long index, int count, long timeout)
void	fetchPartitionAsync(BrokerNode brokerNode, String topic, String app, short partition, int count, long timeout, PartitionFetchListener listener)
void	fetchPartitionAsync(BrokerNode brokerNode, String topic, String app, short partition, long index, int count, long timeout, PartitionFetchListener listener)

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

start, stop

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

isStarted

方法详细资料

fetch

FetchMessageData fetch(BrokerNode brokerNode,
                       String topic,
                       String app,
                       int count,
                       long timeout,
                       long ackTimeout,
                       long longPollTimeout)

asyncFetch

void asyncFetch(BrokerNode brokerNode,
                String topic,
                String app,
                int count,
                long timeout,
                long ackTimeout,
                long longPollTimeout,
                FetchListener listener)

fetchPartition

FetchMessageData fetchPartition(BrokerNode brokerNode,
                                String topic,
                                String app,
                                short partition,
                                int count,
                                long timeout)

fetchPartitionAsync

void fetchPartitionAsync(BrokerNode brokerNode,
                         String topic,
                         String app,
                         short partition,
                         int count,
                         long timeout,
                         PartitionFetchListener listener)

fetchPartition

FetchMessageData fetchPartition(BrokerNode brokerNode,
                                String topic,
                                String app,
                                short partition,
                                long index,
                                int count,
                                long timeout)

fetchPartitionAsync

void fetchPartitionAsync(BrokerNode brokerNode,
                         String topic,
                         String app,
                         short partition,
                         long index,
                         int count,
                         long timeout,
                         PartitionFetchListener listener)

batchFetch

Map<String,FetchMessageData> batchFetch(BrokerNode brokerNode,
                                        List<String> topics,
                                        String app,
                                        int count,
                                        long timeout,
                                        long ackTimeout,
                                        long longPollTimeout)

batchFetchAsync

void batchFetchAsync(BrokerNode brokerNode,
                     List<String> topics,
                     String app,
                     int count,
                     long timeout,
                     long ackTimeout,
                     long longPollTimeout,
                     BatchFetchListener listener)

batchFetchPartitions

com.google.common.collect.Table<String,Short,FetchMessageData> batchFetchPartitions(BrokerNode brokerNode,
                                                                                    Map<String,Short> partitions,
                                                                                    String app,
                                                                                    int count,
                                                                                    long timeout)

batchFetchPartitionsAsync

void batchFetchPartitionsAsync(BrokerNode brokerNode,
                               Map<String,Short> partitions,
                               String app,
                               int count,
                               long timeout,
                               BatchPartitionFetchListener listener)

batchFetchPartitions

com.google.common.collect.Table<String,Short,FetchMessageData> batchFetchPartitions(BrokerNode brokerNode,
                                                                                    com.google.common.collect.Table<String,Short,Long> partitions,
                                                                                    String app,
                                                                                    int count,
                                                                                    long timeout)

batchFetchPartitionsAsync

void batchFetchPartitionsAsync(BrokerNode brokerNode,
                               com.google.common.collect.Table<String,Short,Long> partitions,
                               String app,
                               int count,
                               long timeout,
                               BatchPartitionFetchListener listener)