org.joyqueue.client.internal.consumer.support

类 MessagePollerInner

java.lang.Object

org.joyqueue.toolkit.service.Activity

org.joyqueue.toolkit.service.Service

org.joyqueue.client.internal.consumer.support.MessagePollerInner

所有已实现的接口:

LifeCycle, Online

public class MessagePollerInner
extends Service

MessagePollerInner author: gaohaoxiang date: 2019/1/4

嵌套类概要

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

Service.Election, Service.ElectionListener

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

Activity.ServiceState

字段概要

字段

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

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

readLock, rwLock, serviceState, signal, started, writeLock

构造器概要

构造器

构造器和说明
MessagePollerInner(ConsumerConfig config, NameServerConfig nameServerConfig, ClusterManager clusterManager, ConsumerClientManager consumerClientManager, MessageFetcher messageFetcher)

方法概要

限定符和类型	方法和说明
BrokerAssignments	buildAllBrokerAssignments(TopicMetadata topicMetadata)
List<ConsumeMessage>	buildPollEmptyResult(PollerListener listener)
protected TraceCaller	buildTraceCaller(TopicMetadata topicMetadata)
protected List<ConsumeMessage>	doFetchPartition(BrokerNode brokerNode, TopicMetadata topicMetadata, short partition, long index, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
protected List<ConsumeMessage>	doFetchTopic(BrokerNode brokerNode, TopicMetadata topicMetadata, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
List<ConsumeMessage>	fetchPartition(BrokerNode brokerNode, String topic, short partition, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
List<ConsumeMessage>	fetchPartition(BrokerNode brokerNode, String topic, short partition, long index, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
List<ConsumeMessage>	fetchPartition(BrokerNode brokerNode, TopicMetadata topicMetadata, short partition, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
List<ConsumeMessage>	fetchPartition(BrokerNode brokerNode, TopicMetadata topicMetadata, short partition, long index, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
List<ConsumeMessage>	fetchTopic(BrokerNode brokerNode, String topic, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
List<ConsumeMessage>	fetchTopic(BrokerNode brokerNode, TopicMetadata topicMetadata, int batchSize, long timeout, TimeUnit timeoutUnit, PollerListener listener)
BrokerAssignments	filterNotAvailableBrokers(BrokerAssignments brokerAssignments)
BrokerAssignments	filterRegionBrokers(TopicMetadata topicMetadata, BrokerAssignments brokerAssignments)
TopicMetadata	getAndCheckTopicMetadata(String topic)
BrokerLoadBalance	getBrokerLoadBalance(String topic)
String	getTopicFullName(String topic)
protected List<ConsumeMessage>	handleFetchMessageData(String topic, String app, FetchMessageData fetchMessageData)
protected void	validate()

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

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

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

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

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

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

字段详细资料

FETCH_PARTITION_NONE_INDEX

public static final long FETCH_PARTITION_NONE_INDEX

另请参阅:

常量字段值

logger

protected static final org.slf4j.Logger logger

构造器详细资料

MessagePollerInner

public MessagePollerInner(ConsumerConfig config,
                          NameServerConfig nameServerConfig,
                          ClusterManager clusterManager,
                          ConsumerClientManager consumerClientManager,
                          MessageFetcher messageFetcher)

方法详细资料

validate

protected void validate()
                 throws Exception

覆盖:

validate 在类中 Service

抛出:

Exception

fetchTopic

public List<ConsumeMessage> fetchTopic(BrokerNode brokerNode,
                                       String topic,
                                       int batchSize,
                                       long timeout,
                                       TimeUnit timeoutUnit,
                                       PollerListener listener)

fetchTopic

public List<ConsumeMessage> fetchTopic(BrokerNode brokerNode,
                                       TopicMetadata topicMetadata,
                                       int batchSize,
                                       long timeout,
                                       TimeUnit timeoutUnit,
                                       PollerListener listener)

doFetchTopic

protected List<ConsumeMessage> doFetchTopic(BrokerNode brokerNode,
                                            TopicMetadata topicMetadata,
                                            int batchSize,
                                            long timeout,
                                            TimeUnit timeoutUnit,
                                            PollerListener listener)

fetchPartition

public List<ConsumeMessage> fetchPartition(BrokerNode brokerNode,
                                           String topic,
                                           short partition,
                                           int batchSize,
                                           long timeout,
                                           TimeUnit timeoutUnit,
                                           PollerListener listener)

fetchPartition

public List<ConsumeMessage> fetchPartition(BrokerNode brokerNode,
                                           TopicMetadata topicMetadata,
                                           short partition,
                                           int batchSize,
                                           long timeout,
                                           TimeUnit timeoutUnit,
                                           PollerListener listener)

fetchPartition

public List<ConsumeMessage> fetchPartition(BrokerNode brokerNode,
                                           String topic,
                                           short partition,
                                           long index,
                                           int batchSize,
                                           long timeout,
                                           TimeUnit timeoutUnit,
                                           PollerListener listener)

fetchPartition

public List<ConsumeMessage> fetchPartition(BrokerNode brokerNode,
                                           TopicMetadata topicMetadata,
                                           short partition,
                                           long index,
                                           int batchSize,
                                           long timeout,
                                           TimeUnit timeoutUnit,
                                           PollerListener listener)

doFetchPartition

protected List<ConsumeMessage> doFetchPartition(BrokerNode brokerNode,
                                                TopicMetadata topicMetadata,
                                                short partition,
                                                long index,
                                                int batchSize,
                                                long timeout,
                                                TimeUnit timeoutUnit,
                                                PollerListener listener)

handleFetchMessageData

protected List<ConsumeMessage> handleFetchMessageData(String topic,
                                                      String app,
                                                      FetchMessageData fetchMessageData)

buildTraceCaller

protected TraceCaller buildTraceCaller(TopicMetadata topicMetadata)

filterRegionBrokers

public BrokerAssignments filterRegionBrokers(TopicMetadata topicMetadata,
                                             BrokerAssignments brokerAssignments)

filterNotAvailableBrokers

public BrokerAssignments filterNotAvailableBrokers(BrokerAssignments brokerAssignments)

getBrokerLoadBalance

public BrokerLoadBalance getBrokerLoadBalance(String topic)

buildPollEmptyResult

public List<ConsumeMessage> buildPollEmptyResult(PollerListener listener)

buildAllBrokerAssignments

public BrokerAssignments buildAllBrokerAssignments(TopicMetadata topicMetadata)

getAndCheckTopicMetadata

public TopicMetadata getAndCheckTopicMetadata(String topic)

getTopicFullName

public String getTopicFullName(String topic)