diff --git a/src/sentry/src/Tracing/Aspect/AmqpProducerAspect.php b/src/sentry/src/Tracing/Aspect/AmqpProducerAspect.php index fda106f24..4430f6552 100644 --- a/src/sentry/src/Tracing/Aspect/AmqpProducerAspect.php +++ b/src/sentry/src/Tracing/Aspect/AmqpProducerAspect.php @@ -25,6 +25,7 @@ use Sentry\Util\SentryUid; use function FriendsOfHyperf\Sentry\trace; +use function Hyperf\Config\config; /** * @property array{application_headers?:AMQPTable} $properties @@ -86,6 +87,7 @@ function (Scope $scope) use ($proceedingJoinPoint, $producerMessage, $messageId, 'message_id' => $messageId, 'destination_name' => $destinationName, 'body_size' => $bodySize, + 'producer' => config('app_name', 'unknown'), ]); (function () use ($carrier) { $this->properties['application_headers'] ??= new AMQPTable(); diff --git a/src/sentry/src/Tracing/Listener/EventHandleListener.php b/src/sentry/src/Tracing/Listener/EventHandleListener.php index 5b1f235e6..2562a7c9c 100644 --- a/src/sentry/src/Tracing/Listener/EventHandleListener.php +++ b/src/sentry/src/Tracing/Listener/EventHandleListener.php @@ -586,6 +586,7 @@ protected function handleAmqpMessageProcessing(AmqpEvent\BeforeConsume $event): 'messaging.message.body.size' => $carrier?->get('body_size'), 'messaging.message.receive.latency' => $carrier?->has('publish_time') ? (microtime(true) - $carrier->get('publish_time')) : null, 'messaging.message.retry.count' => 0, + 'messaging.message.producer' => $carrier?->get('producer', 'unknown'), 'messaging.destination.name' => $carrier?->get('destination_name') ?: implode(', ', (array) $message->getRoutingKey()), 'messaging.amqp.message.type' => $message->getTypeString(), 'messaging.amqp.message.routing_key' => $message->getRoutingKey(),