io.openmessaging.joyqueue.consumer.support

类 ConsumerImpl

java.lang.Object

org.joyqueue.toolkit.service.Activity

org.joyqueue.toolkit.service.Service

io.openmessaging.joyqueue.support.AbstractServiceLifecycle

io.openmessaging.joyqueue.consumer.support.ConsumerImpl

所有已实现的接口:

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

public class ConsumerImpl
extends AbstractServiceLifecycle
implements ExtensionConsumer

ConsumerImpl author: gaohaoxiang date: 2019/2/19

嵌套类概要

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

Service.Election, Service.ElectionListener

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

Activity.ServiceState

字段概要

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

readLock, rwLock, serviceState, signal, started, writeLock

构造器概要

构造器

构造器和说明
ConsumerImpl(MessageConsumer messageConsumer)

方法概要

限定符和类型	方法和说明
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)
protected void	doStart()
protected void	doStop()
String	getBindQueue()
Optional<io.openmessaging.extension.Extension>	getExtension()
ConsumerIndex	getIndex(short partition)
io.openmessaging.extension.QueueMetaData	getQueueMetaData(String queueName)
protected io.openmessaging.exception.OMSRuntimeException	handleConsumeException(Throwable cause)
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	suspend()
void	suspend(long timeout)
void	unbindQueue(String queueName)

从类继承的方法 io.openmessaging.joyqueue.support.AbstractServiceLifecycle

currentState, start, stop

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

getServiceState, isReady, isStarted, isStopped, stop, validate, willStop

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

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

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

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

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

currentState, start, stop

构造器详细资料

ConsumerImpl

public ConsumerImpl(MessageConsumer messageConsumer)

方法详细资料

doStart

protected void doStart()
                throws Exception

覆盖:

doStart 在类中 Activity

抛出:

Exception

doStop

protected void doStop()

覆盖:

doStop 在类中 Activity

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

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

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

getQueueMetaData

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

指定者:

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

getIndex

public ConsumerIndex getIndex(short partition)

指定者:

getIndex 在接口中 ExtensionConsumer

handleConsumeException

protected io.openmessaging.exception.OMSRuntimeException handleConsumeException(Throwable cause)