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

Class AbstractMessageConsumeInterceptor

java.lang.Object

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

All Implemented Interfaces:

org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.InstanceMethodsAroundInterceptor

Direct Known Subclasses:

MessageConcurrentlyConsumeInterceptor, MessageOrderlyConsumeInterceptor

public abstract class AbstractMessageConsumeInterceptor
extends Object
implements org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.InstanceMethodsAroundInterceptor

AbstractMessageConsumeInterceptor create entry span when the consumeMessage in the MessageListenerConcurrently and MessageListenerOrderly class.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CONSUMER_OPERATION_NAME_PREFIX

Constructor Summary

Constructors

Constructor	Description
AbstractMessageConsumeInterceptor()

Method Summary

Modifier and Type	Method	Description
final void	beforeMethod(org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.EnhancedInstance objInst, Method method, Object[] allArguments, Class<?>[] argumentsTypes, org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.MethodInterceptResult result)
final void	handleMethodException(org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.EnhancedInstance objInst, Method method, Object[] allArguments, Class<?>[] argumentsTypes, Throwable t)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.InstanceMethodsAroundInterceptor

afterMethod

Field Details

CONSUMER_OPERATION_NAME_PREFIX

public static final String CONSUMER_OPERATION_NAME_PREFIX

See Also:

• Constant Field Values

Constructor Details

AbstractMessageConsumeInterceptor

public AbstractMessageConsumeInterceptor()

Method Details

beforeMethod

public final void beforeMethod(org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.EnhancedInstance objInst,
 Method method,
 Object[] allArguments,
 Class<?>[] argumentsTypes,
 org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.MethodInterceptResult result)
                        throws Throwable

Specified by:

beforeMethod in interface org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.InstanceMethodsAroundInterceptor

Throws:

Throwable

handleMethodException

public final void handleMethodException(org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.EnhancedInstance objInst,
 Method method,
 Object[] allArguments,
 Class<?>[] argumentsTypes,
 Throwable t)

Specified by:

handleMethodException in interface org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.InstanceMethodsAroundInterceptor