apm-agent-plugins/apm-rabbitmq/apm-rabbitmq-spring5/src/main/java/co/elastic/apm/agent/rabbitmq/SpringAmqpMessageListenerInstrumentation.java [76:84]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        public static void afterMessageHandle(@Advice.Enter @Nullable final Object transactionObject,
                                              @Advice.Thrown @Nullable final Throwable throwable) {
            if (transactionObject instanceof Transaction<?>) {
                Transaction<?> transaction = (Transaction<?>) transactionObject;
                transaction.captureException(throwable)
                    .deactivate()
                    .end();
            }
        }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



apm-agent-plugins/apm-rabbitmq/apm-rabbitmq-plugin/src/main/java/co/elastic/apm/agent/rabbitmq/ConsumerInstrumentation.java [125:133]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        public static void afterHandleDelivery(@Advice.Enter @Nullable final Object transactionObject,
                                               @Advice.Thrown @Nullable final Throwable throwable) {
            if (transactionObject instanceof Transaction<?>) {
                Transaction<?> transaction = (Transaction<?>) transactionObject;
                transaction.captureException(throwable)
                    .deactivate()
                    .end();
            }
        }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -