apm-sniffer/apm-sdk-plugin/rocketMQ-5.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/rocketMQ/v5/OnExceptionInterceptor.java [41:56]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void beforeMethod(EnhancedInstance objInst, Method method, Object[] allArguments, Class<?>[] argumentsTypes,
        MethodInterceptResult result) throws Throwable {
        SendCallBackEnhanceInfo enhanceInfo = (SendCallBackEnhanceInfo) objInst.getSkyWalkingDynamicField();
        String topicId = DEFAULT_TOPIC;
        // The SendCallBackEnhanceInfo could be null when there is an internal exception in the client API,
        // such as MQClientException("no route info of this topic")
        if (enhanceInfo != null) {
            topicId = enhanceInfo.getTopicId();
        }
        AbstractSpan activeSpan = ContextManager.createLocalSpan(CALLBACK_OPERATION_NAME_PREFIX + topicId + "/Producer/Callback");
        activeSpan.setComponent(ComponentsDefine.ROCKET_MQ_PRODUCER);
        activeSpan.log((Throwable) allArguments[0]);
        if (enhanceInfo != null && enhanceInfo.getContextSnapshot() != null) {
            ContextManager.continued(enhanceInfo.getContextSnapshot());
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



apm-sniffer/apm-sdk-plugin/rocketMQ-4.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/rocketMQ/v4/OnExceptionInterceptor.java [40:55]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void beforeMethod(EnhancedInstance objInst, Method method, Object[] allArguments, Class<?>[] argumentsTypes,
        MethodInterceptResult result) throws Throwable {
        SendCallBackEnhanceInfo enhanceInfo = (SendCallBackEnhanceInfo) objInst.getSkyWalkingDynamicField();
        String topicId = DEFAULT_TOPIC;
        // The SendCallBackEnhanceInfo could be null when there is an internal exception in the client API,
        // such as MQClientException("no route info of this topic")
        if (enhanceInfo != null) {
            topicId = enhanceInfo.getTopicId();
        }
        AbstractSpan activeSpan = ContextManager.createLocalSpan(CALLBACK_OPERATION_NAME_PREFIX + topicId + "/Producer/Callback");
        activeSpan.setComponent(ComponentsDefine.ROCKET_MQ_PRODUCER);
        activeSpan.log((Throwable) allArguments[0]);
        if (enhanceInfo != null && enhanceInfo.getContextSnapshot() != null) {
            ContextManager.continued(enhanceInfo.getContextSnapshot());
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -