io.openmessaging.joyqueue.consumer

接口 ExtensionConsumer

所有超级接口:

io.openmessaging.Client, io.openmessaging.consumer.Consumer, io.openmessaging.extension.Extension, io.openmessaging.ServiceLifecycle

所有已知实现类:

ConsumerImpl, ConsumerWrapper

public interface ExtensionConsumer
extends io.openmessaging.consumer.Consumer

ExtensionConsumer author: gaohaoxiang date: 2019/3/4

方法概要

限定符和类型	方法和说明
List<io.openmessaging.message.Message>	batchReceive(short partition, long timeout)
List<io.openmessaging.message.Message>	batchReceive(short partition, long index, long timeout)
ConsumerIndex	getIndex(short partition)
io.openmessaging.message.Message	receive(short partition, long timeout)
io.openmessaging.message.Message	receive(short partition, long index, long timeout)

从接口继承的方法 io.openmessaging.consumer.Consumer

ack, addInterceptor, batchReceive, bindQueue, bindQueue, bindQueue, getBindQueue, isBindQueue, isSuspended, receive, removeInterceptor, resume, suspend, suspend, unbindQueue

从接口继承的方法 io.openmessaging.ServiceLifecycle

currentState, start, stop

从接口继承的方法 io.openmessaging.extension.Extension

getQueueMetaData

从接口继承的方法 io.openmessaging.Client

getExtension

方法详细资料

receive

io.openmessaging.message.Message receive(short partition,
                                         long timeout)

batchReceive

List<io.openmessaging.message.Message> batchReceive(short partition,
                                                    long timeout)

receive

io.openmessaging.message.Message receive(short partition,
                                         long index,
                                         long timeout)

batchReceive

List<io.openmessaging.message.Message> batchReceive(short partition,
                                                    long index,
                                                    long timeout)

getIndex

ConsumerIndex getIndex(short partition)