From adedc8f535a66c8482e776a6c4c72b8dad069682 Mon Sep 17 00:00:00 2001
From: siam <hzh@addcn.com>
Date: Fri, 3 Jul 2026 18:15:23 +0800
Subject: [PATCH] add ignore amqp consumer

---
 src/sentry/publish/sentry.php                           | 5 +++++
 src/sentry/src/Tracing/Listener/EventHandleListener.php | 7 +++++++
 2 files changed, 12 insertions(+)

diff --git a/src/sentry/publish/sentry.php b/src/sentry/publish/sentry.php
index d23c25081..9bdbbd620 100644
--- a/src/sentry/publish/sentry.php
+++ b/src/sentry/publish/sentry.php
@@ -133,6 +133,11 @@
         'vendor:publish',
     ],
 
+    // AMQP consumers to ignore for performance monitoring
+    'ignore_amqp_consumer' => [
+        // App\Amqp\Consumers\DemoConsumer::class,
+    ],
+
     // Performance monitoring specific configuration
     'tracing' => [
         'amqp' => env('SENTRY_TRACING_ENABLE_AMQP', true),
diff --git a/src/sentry/src/Tracing/Listener/EventHandleListener.php b/src/sentry/src/Tracing/Listener/EventHandleListener.php
index fa4a2b2b6..adf7e5e97 100644
--- a/src/sentry/src/Tracing/Listener/EventHandleListener.php
+++ b/src/sentry/src/Tracing/Listener/EventHandleListener.php
@@ -65,12 +65,15 @@ class EventHandleListener implements ListenerInterface
 
     protected array $ignoreCommands = [];
 
+    protected array $ignoreAmqpConsumer = [];
+
     public function __construct(
         protected ContainerInterface $container,
         protected ConfigInterface $config,
         protected Feature $feature
     ) {
         $this->ignoreCommands = (array) $this->config->get('sentry.ignore_commands', []);
+        $this->ignoreAmqpConsumer = (array) $this->config->get('sentry.ignore_amqp_consumer', []);
     }
 
     public function listen(): array
@@ -559,6 +562,10 @@ protected function handleAmqpMessageProcessing(AmqpEvent\BeforeConsume $event):
 
         /** @var ConsumerMessage $message */
         $message = $event->getMessage();
+        if (in_array($message::class, $this->ignoreAmqpConsumer, true)) {
+            return;
+        }
+
         $carrier = null;
 
         if (method_exists($event, 'getAMQPMessage')) {