程序包 org.joyqueue.client.internal.consumer.support

类概要

类	说明
BatchConsumerInvoker	BatchConsumerInvoker author: gaohaoxiang date: 2019/1/11
BroadcastMessagePoller	BroadcastMessagePoller author: gaohaoxiang date: 2018/12/14
BrokerLoadBalanceManager	BrokerLoadBalanceManager author: gaohaoxiang date: 2019/1/3
CompletableFuturePollerListener	CompletableFuturePollerListener author: gaohaoxiang date: 2019/7/25
ConsumerLocalIndexStore	ConsumerLocalIndexStore author: gaohaoxiang date: 2018/12/14
DefaultConsumerIndexManager	DefaultConsumerIndexManager author: gaohaoxiang date: 2018/12/12
DefaultMessageConsumer	DefaultMessageConsumer author: gaohaoxiang date: 2019/1/10
DefaultMessageFetcher	DefaultMessageFetcher author: gaohaoxiang date: 2018/12/7
DefaultMessagePoller	DefaultMessagePoller author: gaohaoxiang date: 2018/12/11
LocalConsumerIndexManager	LocalConsumerIndexManager author: gaohaoxiang date: 2018/12/14
MessageConsumerWrapper	MessageConsumerWrapper author: gaohaoxiang date: 2019/1/10
MessageFetcherWrapper	MessageFetcherWrapper author: gaohaoxiang date: 2018/12/27
MessageListenerManager	MessageListenerManager author: gaohaoxiang date: 2018/12/25
MessagePollerInner	MessagePollerInner author: gaohaoxiang date: 2019/1/4
MessagePollerWrapper	MessagePollerWrapper author: gaohaoxiang date: 2018/12/27
OnceConsumerInvoker	OnceConsumerInvoker author: gaohaoxiang date: 2019/1/11
PartitionMessagePoller	PartitionMessagePoller author: gaohaoxiang date: 2018/12/14
RandomBrokerLoadBalance	RandomBrokerLoadBalance author: gaohaoxiang date: 2018/12/12
RoundRobinBrokerLoadBalance	RoundRobinBrokerLoadBalance author: gaohaoxiang date: 2018/12/11
TopicMessageConsumer	TopicMessageConsumerGroup author: gaohaoxiang date: 2018/12/25
TopicMessageConsumerDispatcher	TopicMessageConsumerDispatcher author: gaohaoxiang date: 2018/12/25
TopicMessageConsumerScheduler	TopicMessageConsumerScheduler author: gaohaoxiang date: 2018/12/25