org.joyqueue.client.internal.consumer.support

类 DefaultMessageFetcher

java.lang.Object

org.joyqueue.toolkit.service.Activity

org.joyqueue.toolkit.service.Service

org.joyqueue.client.internal.consumer.support.DefaultMessageFetcher

所有已实现的接口:

MessageFetcher, LifeCycle, Online

public class DefaultMessageFetcher
extends Service
implements MessageFetcher

DefaultMessageFetcher author: gaohaoxiang date: 2018/12/7

嵌套类概要

从类继承的嵌套类/接口 org.joyqueue.toolkit.service.Service

Service.Election, Service.ElectionListener

从类继承的嵌套类/接口 org.joyqueue.toolkit.service.Activity

Activity.ServiceState

字段概要

字段

限定符和类型	字段和说明
protected static org.slf4j.Logger	logger

从类继承的字段 org.joyqueue.toolkit.service.Activity

readLock, rwLock, serviceState, signal, started, writeLock

构造器概要

构造器

构造器和说明
DefaultMessageFetcher(ConsumerClientManager consumerClientManager, FetcherConfig config)

方法概要

限定符和类型	方法和说明
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)
protected void	checkState()
protected void	doStop()
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)
protected void	handleAddConsumers(BrokerNode brokerNode, Collection<String> topics, String app, ConsumerClient client)
protected void	handleRemoveConsumers()
protected void	handleRemoveConsumers(BrokerNode brokerNode, Set<String> topics, Set<String> apps)

从类继承的方法 org.joyqueue.toolkit.service.Service

getServiceState, isReady, isStarted, isStopped, start, stop, stop, validate, willStop

从类继承的方法 org.joyqueue.toolkit.service.Activity

afterStart, afterStop, await, beforeStart, beforeStop, convert, doStart, getReadLock, getWriteLock, startError

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

start, stop

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

isStarted

字段详细资料

logger

protected static final org.slf4j.Logger logger

构造器详细资料

DefaultMessageFetcher

public DefaultMessageFetcher(ConsumerClientManager consumerClientManager,
                             FetcherConfig config)

方法详细资料

fetch

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

指定者:

fetch 在接口中 MessageFetcher

asyncFetch

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

指定者:

asyncFetch 在接口中 MessageFetcher

fetchPartition

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

指定者:

fetchPartition 在接口中 MessageFetcher

fetchPartitionAsync

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

指定者:

fetchPartitionAsync 在接口中 MessageFetcher

fetchPartition

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

指定者:

fetchPartition 在接口中 MessageFetcher

fetchPartitionAsync

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

指定者:

fetchPartitionAsync 在接口中 MessageFetcher

batchFetch

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

指定者:

batchFetch 在接口中 MessageFetcher

batchFetchAsync

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

指定者:

batchFetchAsync 在接口中 MessageFetcher

batchFetchPartitions

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

指定者:

batchFetchPartitions 在接口中 MessageFetcher

batchFetchPartitionsAsync

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

指定者:

batchFetchPartitionsAsync 在接口中 MessageFetcher

batchFetchPartitions

public 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)

指定者:

batchFetchPartitions 在接口中 MessageFetcher

batchFetchPartitionsAsync

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

指定者:

batchFetchPartitionsAsync 在接口中 MessageFetcher

checkState

protected void checkState()

handleAddConsumers

protected void handleAddConsumers(BrokerNode brokerNode,
                                  Collection<String> topics,
                                  String app,
                                  ConsumerClient client)

doStop

protected void doStop()

覆盖:

doStop 在类中 Activity

handleRemoveConsumers

protected void handleRemoveConsumers()

handleRemoveConsumers

protected void handleRemoveConsumers(BrokerNode brokerNode,
                                     Set<String> topics,
                                     Set<String> apps)