io.openmessaging.joyqueue.consumer.support

类 ConsumerInterceptorAdapter

java.lang.Object

io.openmessaging.joyqueue.consumer.support.ConsumerInterceptorAdapter

所有已实现的接口:

BaseInterceptor, ConsumerInterceptor

public class ConsumerInterceptorAdapter
extends Object
implements ConsumerInterceptor

ConsumerInterceptorAdapter author: gaohaoxiang date: 2019/2/20

构造器概要

构造器

构造器和说明
ConsumerInterceptorAdapter(io.openmessaging.interceptor.ConsumerInterceptor omsConsumerInterceptor)

方法概要

限定符和类型	方法和说明
boolean	equals(Object obj)
io.openmessaging.interceptor.ConsumerInterceptor	getOmsConsumerInterceptor()
protected List<io.openmessaging.message.Message>	getOrConvertMessages(ConsumeContext context)
protected io.openmessaging.interceptor.Context	getOrCreateOMSContext(ConsumeContext context)
int	hashCode()
void	postConsume(ConsumeContext context, List<ConsumeReply> consumeReplies)
boolean	preConsume(ConsumeContext context)
String	toString()

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

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

构造器详细资料

ConsumerInterceptorAdapter

public ConsumerInterceptorAdapter(io.openmessaging.interceptor.ConsumerInterceptor omsConsumerInterceptor)

方法详细资料

preConsume

public boolean preConsume(ConsumeContext context)

指定者:

preConsume 在接口中 ConsumerInterceptor

postConsume

public void postConsume(ConsumeContext context,
                        List<ConsumeReply> consumeReplies)

指定者:

postConsume 在接口中 ConsumerInterceptor

getOrConvertMessages

protected List<io.openmessaging.message.Message> getOrConvertMessages(ConsumeContext context)

getOrCreateOMSContext

protected io.openmessaging.interceptor.Context getOrCreateOMSContext(ConsumeContext context)

hashCode

public int hashCode()

覆盖:

hashCode 在类中 Object

equals

public boolean equals(Object obj)

覆盖:

equals 在类中 Object

toString

public String toString()

覆盖:

toString 在类中 Object

getOmsConsumerInterceptor

public io.openmessaging.interceptor.ConsumerInterceptor getOmsConsumerInterceptor()