org.joyqueue.client.internal.consumer

接口 MessageConsumer

所有超级接口:

LifeCycle, Online

所有已知实现类:

DefaultMessageConsumer, MessageConsumerWrapper

public interface MessageConsumer
extends LifeCycle

MessageConsumer author: gaohaoxiang date: 2019/1/10

方法概要

限定符和类型	方法和说明
void	addInterceptor(ConsumerInterceptor interceptor)
FetchIndexData	fetchIndex(short partition)
TopicMetadata	getTopicMetadata(String topic)
boolean	isListenSuspended()
boolean	isSubscribed()
List<ConsumeMessage>	poll()
List<ConsumeMessage>	poll(long timeout, TimeUnit timeoutUnit)
CompletableFuture<List<ConsumeMessage>>	pollAsync()
CompletableFuture<List<ConsumeMessage>>	pollAsync(long timeout, TimeUnit timeoutUnit)
ConsumeMessage	pollOnce()
ConsumeMessage	pollOnce(long timeout, TimeUnit timeoutUnit)
List<ConsumeMessage>	pollPartition(short partition)
List<ConsumeMessage>	pollPartition(short partition, long index)
List<ConsumeMessage>	pollPartition(short partition, long index, long timeout, TimeUnit timeoutUnit)
List<ConsumeMessage>	pollPartition(short partition, long timeout, TimeUnit timeoutUnit)
CompletableFuture<List<ConsumeMessage>>	pollPartitionAsync(short partition)
CompletableFuture<List<ConsumeMessage>>	pollPartitionAsync(short partition, long index)
CompletableFuture<List<ConsumeMessage>>	pollPartitionAsync(short partition, long index, long timeout, TimeUnit timeoutUnit)
CompletableFuture<List<ConsumeMessage>>	pollPartitionAsync(short partition, long timeout, TimeUnit timeoutUnit)
ConsumeMessage	pollPartitionOnce(short partition)
ConsumeMessage	pollPartitionOnce(short partition, long index)
ConsumeMessage	pollPartitionOnce(short partition, long index, long timeout, TimeUnit timeoutUnit)
ConsumeMessage	pollPartitionOnce(short partition, long timeout, TimeUnit timeoutUnit)
void	removeInterceptor(ConsumerInterceptor interceptor)
org.joyqueue.exception.JoyQueueCode	reply(List<ConsumeReply> replyList)
org.joyqueue.exception.JoyQueueCode	replyOnce(ConsumeReply reply)
void	resumeListen()
void	subscribe(String topic)
void	subscribe(String topic, MessageListener messageListener)
void	subscribeBatch(String topic, BatchMessageListener batchMessageListener)
String	subscription()
void	suspendListen()
void	unsubscribe()

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

start, stop

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

isStarted

方法详细资料

subscribe

void subscribe(String topic)

unsubscribe

void unsubscribe()

subscription

String subscription()

isSubscribed

boolean isSubscribed()

subscribe

void subscribe(String topic,
               MessageListener messageListener)

subscribeBatch

void subscribeBatch(String topic,
                    BatchMessageListener batchMessageListener)

resumeListen

void resumeListen()

suspendListen

void suspendListen()

isListenSuspended

boolean isListenSuspended()

addInterceptor

void addInterceptor(ConsumerInterceptor interceptor)

removeInterceptor

void removeInterceptor(ConsumerInterceptor interceptor)

pollOnce

ConsumeMessage pollOnce()

pollOnce

ConsumeMessage pollOnce(long timeout,
                        TimeUnit timeoutUnit)

poll

List<ConsumeMessage> poll()

poll

List<ConsumeMessage> poll(long timeout,
                          TimeUnit timeoutUnit)

pollAsync

CompletableFuture<List<ConsumeMessage>> pollAsync()

pollAsync

CompletableFuture<List<ConsumeMessage>> pollAsync(long timeout,
                                                  TimeUnit timeoutUnit)

pollPartitionOnce

ConsumeMessage pollPartitionOnce(short partition)

pollPartitionOnce

ConsumeMessage pollPartitionOnce(short partition,
                                 long timeout,
                                 TimeUnit timeoutUnit)

pollPartitionOnce

ConsumeMessage pollPartitionOnce(short partition,
                                 long index)

pollPartitionOnce

ConsumeMessage pollPartitionOnce(short partition,
                                 long index,
                                 long timeout,
                                 TimeUnit timeoutUnit)

pollPartition

List<ConsumeMessage> pollPartition(short partition)

pollPartition

List<ConsumeMessage> pollPartition(short partition,
                                   long timeout,
                                   TimeUnit timeoutUnit)

pollPartition

List<ConsumeMessage> pollPartition(short partition,
                                   long index)

pollPartition

List<ConsumeMessage> pollPartition(short partition,
                                   long index,
                                   long timeout,
                                   TimeUnit timeoutUnit)

pollPartitionAsync

CompletableFuture<List<ConsumeMessage>> pollPartitionAsync(short partition)

pollPartitionAsync

CompletableFuture<List<ConsumeMessage>> pollPartitionAsync(short partition,
                                                           long timeout,
                                                           TimeUnit timeoutUnit)

pollPartitionAsync

CompletableFuture<List<ConsumeMessage>> pollPartitionAsync(short partition,
                                                           long index)

pollPartitionAsync

CompletableFuture<List<ConsumeMessage>> pollPartitionAsync(short partition,
                                                           long index,
                                                           long timeout,
                                                           TimeUnit timeoutUnit)

reply

org.joyqueue.exception.JoyQueueCode reply(List<ConsumeReply> replyList)

replyOnce

org.joyqueue.exception.JoyQueueCode replyOnce(ConsumeReply reply)

fetchIndex

FetchIndexData fetchIndex(short partition)

getTopicMetadata

TopicMetadata getTopicMetadata(String topic)