org.joyqueue.client.internal.consumer.support

类 MessageFetcherWrapper

java.lang.Object

org.joyqueue.toolkit.service.Activity

org.joyqueue.toolkit.service.Service

org.joyqueue.client.internal.consumer.support.MessageFetcherWrapper

所有已实现的接口:

MessageFetcher, LifeCycle, Online

public class MessageFetcherWrapper
extends Service
implements MessageFetcher

MessageFetcherWrapper author: gaohaoxiang date: 2018/12/27

嵌套类概要

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

Service.Election, Service.ElectionListener

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

Activity.ServiceState

字段概要

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

readLock, rwLock, serviceState, signal, started, writeLock

构造器概要

构造器

构造器和说明
MessageFetcherWrapper(ConsumerClientManager consumerClientManager, MessageFetcher delegate)

方法概要

限定符和类型	方法和说明
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	doStart()
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)

从类继承的方法 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, 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

构造器详细资料

MessageFetcherWrapper

public MessageFetcherWrapper(ConsumerClientManager consumerClientManager,
                             MessageFetcher delegate)

方法详细资料

doStart

protected void doStart()
                throws Exception

覆盖:

doStart 在类中 Activity

抛出:

Exception

doStop

protected void doStop()

覆盖:

doStop 在类中 Activity

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