io.openmessaging.joyqueue.support

类 ConsumerWrapper

java.lang.Object

io.openmessaging.joyqueue.support.ConsumerWrapper

所有已实现的接口:

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

public class ConsumerWrapper
extends Object
implements ExtensionConsumer

ConsumerWrapper author: gaohaoxiang date: 2019/5/14

构造器概要

构造器

构造器和说明
ConsumerWrapper(ExtensionConsumer delegate, MessageAccessPointHolder messageAccessPointHolder)

方法概要

限定符和类型	方法和说明
void	ack(io.openmessaging.consumer.MessageReceipt receipt)
void	addInterceptor(io.openmessaging.interceptor.ConsumerInterceptor interceptor)
List<io.openmessaging.message.Message>	batchReceive(long timeout)
List<io.openmessaging.message.Message>	batchReceive(short partition, long timeout)
List<io.openmessaging.message.Message>	batchReceive(short partition, long index, long timeout)
void	bindQueue(String queueName)
void	bindQueue(String queueName, io.openmessaging.consumer.BatchMessageListener listener)
void	bindQueue(String queueName, io.openmessaging.consumer.MessageListener listener)
io.openmessaging.ServiceLifeState	currentState()
String	getBindQueue()
Optional<io.openmessaging.extension.Extension>	getExtension()
ConsumerIndex	getIndex(short partition)
io.openmessaging.extension.QueueMetaData	getQueueMetaData(String queueName)
boolean	isBindQueue()
boolean	isSuspended()
io.openmessaging.message.Message	receive(long timeout)
io.openmessaging.message.Message	receive(short partition, long timeout)
io.openmessaging.message.Message	receive(short partition, long index, long timeout)
void	removeInterceptor(io.openmessaging.interceptor.ConsumerInterceptor interceptor)
void	resume()
void	start()
void	stop()
void	suspend()
void	suspend(long timeout)
void	unbindQueue(String queueName)

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

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

构造器详细资料

ConsumerWrapper

public ConsumerWrapper(ExtensionConsumer delegate,
                       MessageAccessPointHolder messageAccessPointHolder)

方法详细资料

receive

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

指定者:

receive 在接口中 ExtensionConsumer

batchReceive

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

指定者:

batchReceive 在接口中 ExtensionConsumer

receive

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

指定者:

receive 在接口中 ExtensionConsumer

batchReceive

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

指定者:

batchReceive 在接口中 ExtensionConsumer

resume

public void resume()

指定者:

resume 在接口中 io.openmessaging.consumer.Consumer

suspend

public void suspend()

指定者:

suspend 在接口中 io.openmessaging.consumer.Consumer

suspend

public void suspend(long timeout)

指定者:

suspend 在接口中 io.openmessaging.consumer.Consumer

isSuspended

public boolean isSuspended()

指定者:

isSuspended 在接口中 io.openmessaging.consumer.Consumer

bindQueue

public void bindQueue(String queueName)

指定者:

bindQueue 在接口中 io.openmessaging.consumer.Consumer

bindQueue

public void bindQueue(String queueName,
                      io.openmessaging.consumer.MessageListener listener)

指定者:

bindQueue 在接口中 io.openmessaging.consumer.Consumer

bindQueue

public void bindQueue(String queueName,
                      io.openmessaging.consumer.BatchMessageListener listener)

指定者:

bindQueue 在接口中 io.openmessaging.consumer.Consumer

unbindQueue

public void unbindQueue(String queueName)

指定者:

unbindQueue 在接口中 io.openmessaging.consumer.Consumer

isBindQueue

public boolean isBindQueue()

指定者:

isBindQueue 在接口中 io.openmessaging.consumer.Consumer

getBindQueue

public String getBindQueue()

指定者:

getBindQueue 在接口中 io.openmessaging.consumer.Consumer

addInterceptor

public void addInterceptor(io.openmessaging.interceptor.ConsumerInterceptor interceptor)

指定者:

addInterceptor 在接口中 io.openmessaging.consumer.Consumer

removeInterceptor

public void removeInterceptor(io.openmessaging.interceptor.ConsumerInterceptor interceptor)

指定者:

removeInterceptor 在接口中 io.openmessaging.consumer.Consumer

receive

public io.openmessaging.message.Message receive(long timeout)

指定者:

receive 在接口中 io.openmessaging.consumer.Consumer

batchReceive

public List<io.openmessaging.message.Message> batchReceive(long timeout)

指定者:

batchReceive 在接口中 io.openmessaging.consumer.Consumer

ack

public void ack(io.openmessaging.consumer.MessageReceipt receipt)

指定者:

ack 在接口中 io.openmessaging.consumer.Consumer

getExtension

public Optional<io.openmessaging.extension.Extension> getExtension()

指定者:

getExtension 在接口中 io.openmessaging.Client

start

public void start()

指定者:

start 在接口中 io.openmessaging.ServiceLifecycle

stop

public void stop()

指定者:

stop 在接口中 io.openmessaging.ServiceLifecycle

currentState

public io.openmessaging.ServiceLifeState currentState()

指定者:

currentState 在接口中 io.openmessaging.ServiceLifecycle

getQueueMetaData

public io.openmessaging.extension.QueueMetaData getQueueMetaData(String queueName)

指定者:

getQueueMetaData 在接口中 io.openmessaging.extension.Extension

getIndex

public ConsumerIndex getIndex(short partition)

指定者:

getIndex 在接口中 ExtensionConsumer