类的使用
org.joyqueue.client.internal.consumer.interceptor.ConsumeContext

使用ConsumeContext的程序包

程序包	说明
io.openmessaging.joyqueue.consumer.interceptor
io.openmessaging.joyqueue.consumer.support
org.joyqueue.client.internal.consumer.interceptor
org.joyqueue.client.internal.consumer.support
org.joyqueue.client.internal.trace.interceptor

io.openmessaging.joyqueue.consumer.interceptor中ConsumeContext的使用

参数类型为ConsumeContext的io.openmessaging.joyqueue.consumer.interceptor中的构造器

构造器和说明
ContextAdapter(ConsumeContext context)
ContextAttributeAdapter(ConsumeContext context)

io.openmessaging.joyqueue.consumer.support中ConsumeContext的使用

参数类型为ConsumeContext的io.openmessaging.joyqueue.consumer.support中的方法

限定符和类型	方法和说明
protected List<io.openmessaging.message.Message>	ConsumerInterceptorAdapter.getOrConvertMessages(ConsumeContext context)
protected io.openmessaging.interceptor.Context	ConsumerInterceptorAdapter.getOrCreateOMSContext(ConsumeContext context)
void	ConsumerInterceptorAdapter.postConsume(ConsumeContext context, List<ConsumeReply> consumeReplies)
boolean	ConsumerInterceptorAdapter.preConsume(ConsumeContext context)

org.joyqueue.client.internal.consumer.interceptor中ConsumeContext的使用

参数类型为ConsumeContext的org.joyqueue.client.internal.consumer.interceptor中的方法

限定符和类型	方法和说明
List<ConsumeReply>	ConsumerInvoker.invoke(ConsumeContext context)
void	ConsumerInterceptor.postConsume(ConsumeContext context, List<ConsumeReply> consumeReplies)
boolean	ConsumerInterceptor.preConsume(ConsumeContext context)
List<ConsumeReply>	ConsumerInvoker.reject(ConsumeContext context)

org.joyqueue.client.internal.consumer.support中ConsumeContext的使用

参数类型为ConsumeContext的org.joyqueue.client.internal.consumer.support中的方法

限定符和类型	方法和说明
List<ConsumeReply>	BatchConsumerInvoker.invoke(ConsumeContext context)
List<ConsumeReply>	OnceConsumerInvoker.invoke(ConsumeContext context)
List<ConsumeReply>	BatchConsumerInvoker.reject(ConsumeContext context)
List<ConsumeReply>	OnceConsumerInvoker.reject(ConsumeContext context)

org.joyqueue.client.internal.trace.interceptor中ConsumeContext的使用

参数类型为ConsumeContext的org.joyqueue.client.internal.trace.interceptor中的方法

限定符和类型	方法和说明
void	TraceConsumerInterceptor.postConsume(ConsumeContext context, List<ConsumeReply> consumeReplies)
boolean	TraceConsumerInterceptor.preConsume(ConsumeContext context)