Index

A B C D E G H M O R S U W 
All Classes and Interfaces|All Packages|Constant Field Values

A

AbstractMessageConsumeInterceptor - Class in org.apache.skywalking.apm.plugin.rocketMQ.v4
AbstractMessageConsumeInterceptor create entry span when the consumeMessage in the MessageListenerConcurrently and MessageListenerOrderly class.
AbstractMessageConsumeInterceptor() - Constructor for class org.apache.skywalking.apm.plugin.rocketMQ.v4.AbstractMessageConsumeInterceptor
 
AbstractRocketMQInstrumentation - Class in org.apache.skywalking.apm.plugin.rocketMQ.v4.define
 
AbstractRocketMQInstrumentation() - Constructor for class org.apache.skywalking.apm.plugin.rocketMQ.v4.define.AbstractRocketMQInstrumentation
 
afterMethod(EnhancedInstance, Method, Object[], Class<?>[], Object) - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.MessageConcurrentlyConsumeInterceptor
 
afterMethod(EnhancedInstance, Method, Object[], Class<?>[], Object) - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.MessageOrderlyConsumeInterceptor
 
afterMethod(EnhancedInstance, Method, Object[], Class<?>[], Object) - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.MessageSendInterceptor
 
afterMethod(EnhancedInstance, Method, Object[], Class<?>[], Object) - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.OnExceptionInterceptor
 
afterMethod(EnhancedInstance, Method, Object[], Class<?>[], Object) - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.OnSuccessInterceptor
 
afterMethod(EnhancedInstance, Method, Object[], Class<?>[], Object) - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.RegisterMessageListenerInterceptor
 
afterMethod(EnhancedInstance, Method, Object[], Class<?>[], Object) - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.UpdateNameServerInterceptor
 
ASYNC_SEND_OPERATION_NAME_PREFIX - Static variable in class org.apache.skywalking.apm.plugin.rocketMQ.v4.MessageSendInterceptor
 

B

beforeMethod(EnhancedInstance, Method, Object[], Class<?>[], MethodInterceptResult) - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.AbstractMessageConsumeInterceptor
 
beforeMethod(EnhancedInstance, Method, Object[], Class<?>[], MethodInterceptResult) - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.MessageSendInterceptor
 
beforeMethod(EnhancedInstance, Method, Object[], Class<?>[], MethodInterceptResult) - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.OnExceptionInterceptor
 
beforeMethod(EnhancedInstance, Method, Object[], Class<?>[], MethodInterceptResult) - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.OnSuccessInterceptor
 
beforeMethod(EnhancedInstance, Method, Object[], Class<?>[], MethodInterceptResult) - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.RegisterMessageListenerInterceptor
 
beforeMethod(EnhancedInstance, Method, Object[], Class<?>[], MethodInterceptResult) - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.UpdateNameServerInterceptor
 

C

CALLBACK_OPERATION_NAME_PREFIX - Static variable in class org.apache.skywalking.apm.plugin.rocketMQ.v4.OnExceptionInterceptor
 
CALLBACK_OPERATION_NAME_PREFIX - Static variable in class org.apache.skywalking.apm.plugin.rocketMQ.v4.OnSuccessInterceptor
 
Constants - Class in org.apache.skywalking.apm.plugin.rocketMQ.v4.define
 
Constants() - Constructor for class org.apache.skywalking.apm.plugin.rocketMQ.v4.define.Constants
 
ConsumeMessageConcurrentlyInstrumentation - Class in org.apache.skywalking.apm.plugin.rocketMQ.v4.define
 
ConsumeMessageConcurrentlyInstrumentation() - Constructor for class org.apache.skywalking.apm.plugin.rocketMQ.v4.define.ConsumeMessageConcurrentlyInstrumentation
 
ConsumeMessageOrderlyInstrumentation - Class in org.apache.skywalking.apm.plugin.rocketMQ.v4.define
 
ConsumeMessageOrderlyInstrumentation() - Constructor for class org.apache.skywalking.apm.plugin.rocketMQ.v4.define.ConsumeMessageOrderlyInstrumentation
 
CONSUMER_OPERATION_NAME_PREFIX - Static variable in class org.apache.skywalking.apm.plugin.rocketMQ.v4.AbstractMessageConsumeInterceptor
 
ConsumerEnhanceInfos - Class in org.apache.skywalking.apm.plugin.rocketMQ.v4.define
 
ConsumerEnhanceInfos(String) - Constructor for class org.apache.skywalking.apm.plugin.rocketMQ.v4.define.ConsumerEnhanceInfos
 

D

DefaultMQPushConsumerInstrumentation - Class in org.apache.skywalking.apm.plugin.rocketMQ.v4.define
 
DefaultMQPushConsumerInstrumentation() - Constructor for class org.apache.skywalking.apm.plugin.rocketMQ.v4.define.DefaultMQPushConsumerInstrumentation
 

E

enhanceClass() - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.define.ConsumeMessageConcurrentlyInstrumentation
 
enhanceClass() - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.define.ConsumeMessageOrderlyInstrumentation
 
enhanceClass() - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.define.DefaultMQPushConsumerInstrumentation
 
enhanceClass() - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.define.MQClientAPIImplInstrumentation
 
enhanceClass() - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.define.SendCallbackInstrumentation
 

G

getConstructorsInterceptPoints() - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.define.ConsumeMessageConcurrentlyInstrumentation
 
getConstructorsInterceptPoints() - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.define.ConsumeMessageOrderlyInstrumentation
 
getConstructorsInterceptPoints() - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.define.DefaultMQPushConsumerInstrumentation
 
getConstructorsInterceptPoints() - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.define.MQClientAPIImplInstrumentation
 
getConstructorsInterceptPoints() - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.define.SendCallbackInstrumentation
 
getContextSnapshot() - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.define.SendCallBackEnhanceInfo
 
getInstanceMethodsInterceptPoints() - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.define.ConsumeMessageConcurrentlyInstrumentation
 
getInstanceMethodsInterceptPoints() - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.define.ConsumeMessageOrderlyInstrumentation
 
getInstanceMethodsInterceptPoints() - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.define.DefaultMQPushConsumerInstrumentation
 
getInstanceMethodsInterceptPoints() - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.define.MQClientAPIImplInstrumentation
 
getInstanceMethodsInterceptPoints() - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.define.SendCallbackInstrumentation
 
getNamesrvAddr() - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.define.ConsumerEnhanceInfos
 
getTopicId() - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.define.SendCallBackEnhanceInfo
 

H

handleMethodException(EnhancedInstance, Method, Object[], Class<?>[], Throwable) - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.AbstractMessageConsumeInterceptor
 
handleMethodException(EnhancedInstance, Method, Object[], Class<?>[], Throwable) - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.MessageSendInterceptor
 
handleMethodException(EnhancedInstance, Method, Object[], Class<?>[], Throwable) - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.OnExceptionInterceptor
 
handleMethodException(EnhancedInstance, Method, Object[], Class<?>[], Throwable) - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.OnSuccessInterceptor
 
handleMethodException(EnhancedInstance, Method, Object[], Class<?>[], Throwable) - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.RegisterMessageListenerInterceptor
 
handleMethodException(EnhancedInstance, Method, Object[], Class<?>[], Throwable) - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.UpdateNameServerInterceptor
 

M

MessageConcurrentlyConsumeInterceptor - Class in org.apache.skywalking.apm.plugin.rocketMQ.v4
MessageConcurrentlyConsumeInterceptor set the process status after the MessageListenerConcurrently.consumeMessage(java.util.List, org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext) method execute.
MessageConcurrentlyConsumeInterceptor() - Constructor for class org.apache.skywalking.apm.plugin.rocketMQ.v4.MessageConcurrentlyConsumeInterceptor
 
MessageOrderlyConsumeInterceptor - Class in org.apache.skywalking.apm.plugin.rocketMQ.v4
MessageOrderlyConsumeInterceptor set the process status after the MessageListenerOrderly.consumeMessage(java.util.List, org.apache.rocketmq.client.consumer.listener.ConsumeOrderlyContext) method execute.
MessageOrderlyConsumeInterceptor() - Constructor for class org.apache.skywalking.apm.plugin.rocketMQ.v4.MessageOrderlyConsumeInterceptor
 
MessageSendInterceptor - Class in org.apache.skywalking.apm.plugin.rocketMQ.v4
MessageSendInterceptor create exit span when the method MQClientAPIImpl.sendMessage(String, String, Message, org.apache.rocketmq.common.protocol.header.SendMessageRequestHeader, long, org.apache.rocketmq.client.impl.CommunicationMode, org.apache.rocketmq.client.producer.SendCallback, org.apache.rocketmq.client.impl.producer.TopicPublishInfo, org.apache.rocketmq.client.impl.factory.MQClientInstance, int, org.apache.rocketmq.client.hook.SendMessageContext, org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl) execute.
MessageSendInterceptor() - Constructor for class org.apache.skywalking.apm.plugin.rocketMQ.v4.MessageSendInterceptor
 
MQClientAPIImplInstrumentation - Class in org.apache.skywalking.apm.plugin.rocketMQ.v4.define
 
MQClientAPIImplInstrumentation() - Constructor for class org.apache.skywalking.apm.plugin.rocketMQ.v4.define.MQClientAPIImplInstrumentation
 

O

OnExceptionInterceptor - Class in org.apache.skywalking.apm.plugin.rocketMQ.v4
OnExceptionInterceptor create local span when the method SendCallback.onException(Throwable) execute.
OnExceptionInterceptor() - Constructor for class org.apache.skywalking.apm.plugin.rocketMQ.v4.OnExceptionInterceptor
 
OnSuccessInterceptor - Class in org.apache.skywalking.apm.plugin.rocketMQ.v4
OnSuccessInterceptor create local span when the method SendCallback.onSuccess(SendResult) execute.
OnSuccessInterceptor() - Constructor for class org.apache.skywalking.apm.plugin.rocketMQ.v4.OnSuccessInterceptor
 
org.apache.skywalking.apm.plugin.rocketMQ.v4 - package org.apache.skywalking.apm.plugin.rocketMQ.v4
 
org.apache.skywalking.apm.plugin.rocketMQ.v4.define - package org.apache.skywalking.apm.plugin.rocketMQ.v4.define
 

R

REGISTER_MESSAGE_LISTENER_INTERCEPT_CLASS - Static variable in class org.apache.skywalking.apm.plugin.rocketMQ.v4.define.DefaultMQPushConsumerInstrumentation
 
RegisterMessageListenerInterceptor - Class in org.apache.skywalking.apm.plugin.rocketMQ.v4
 
RegisterMessageListenerInterceptor() - Constructor for class org.apache.skywalking.apm.plugin.rocketMQ.v4.RegisterMessageListenerInterceptor
 

S

SendCallBackEnhanceInfo - Class in org.apache.skywalking.apm.plugin.rocketMQ.v4.define
SendCallBackEnhanceInfo saves the topic Id and ContextSnapshot instance for trace.
SendCallBackEnhanceInfo(String, ContextSnapshot) - Constructor for class org.apache.skywalking.apm.plugin.rocketMQ.v4.define.SendCallBackEnhanceInfo
 
SendCallbackInstrumentation - Class in org.apache.skywalking.apm.plugin.rocketMQ.v4.define
 
SendCallbackInstrumentation() - Constructor for class org.apache.skywalking.apm.plugin.rocketMQ.v4.define.SendCallbackInstrumentation
 

U

UPDATE_NAME_SERVER_INTERCEPT_CLASS - Static variable in class org.apache.skywalking.apm.plugin.rocketMQ.v4.define.MQClientAPIImplInstrumentation
 
UPDATE_NAME_SERVER_METHOD_NAME - Static variable in class org.apache.skywalking.apm.plugin.rocketMQ.v4.define.MQClientAPIImplInstrumentation
 
UpdateNameServerInterceptor - Class in org.apache.skywalking.apm.plugin.rocketMQ.v4
 
UpdateNameServerInterceptor() - Constructor for class org.apache.skywalking.apm.plugin.rocketMQ.v4.UpdateNameServerInterceptor
 

W

WITNESS_ROCKETMQ_4X_CLASS - Static variable in class org.apache.skywalking.apm.plugin.rocketMQ.v4.define.Constants
 
witnessClasses() - Method in class org.apache.skywalking.apm.plugin.rocketMQ.v4.define.AbstractRocketMQInstrumentation
 
A B C D E G H M O R S U W 
All Classes and Interfaces|All Packages|Constant Field Values