Uses of Class org.apache.skywalking.apm.plugin.rocketMQ.v4.AbstractMessageConsumeInterceptor (rocketMQ-4.x-plugin 9.4.0 API)

Packages that use AbstractMessageConsumeInterceptor

Package

Description

org.apache.skywalking.apm.plugin.rocketMQ.v4

Uses of AbstractMessageConsumeInterceptor in org.apache.skywalking.apm.plugin.rocketMQ.v4

Subclasses of AbstractMessageConsumeInterceptor in org.apache.skywalking.apm.plugin.rocketMQ.v4

Modifier and Type

Class

Description

class

MessageConcurrentlyConsumeInterceptor

MessageConcurrentlyConsumeInterceptor set the process status after the MessageListenerConcurrently.consumeMessage(java.util.List, org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext) method execute.

class

MessageOrderlyConsumeInterceptor

MessageOrderlyConsumeInterceptor set the process status after the MessageListenerOrderly.consumeMessage(java.util.List, org.apache.rocketmq.client.consumer.listener.ConsumeOrderlyContext) method execute.