Skip to content

Commit d3e37a2

Browse files
committed
fix: handle empty routing key in AmqpProducerAspect and EventHandleListener
1 parent 14267a1 commit d3e37a2

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

src/Tracing/Aspect/AmqpProducerAspect.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ protected function handleProduceMessage(ProceedingJoinPoint $proceedingJoinPoint
7676
}
7777

7878
$messageId = SentryUid::generate();
79-
$destinationName = implode(', ', (array) $routingKey);
79+
$destinationName = empty($routingKey) ? $exchange : implode(', ', (array) $routingKey);
8080
$bodySize = strlen($producerMessage->payload());
8181

8282
return trace(

src/Tracing/Listener/EventHandleListener.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -586,7 +586,7 @@ protected function handleAmqpMessageProcessing(AmqpEvent\BeforeConsume $event):
586586
'messaging.message.receive.latency' => $carrier?->has('publish_time') ? (microtime(true) - $carrier->get('publish_time')) : null,
587587
'messaging.message.retry.count' => 0,
588588
'messaging.message.producer' => $carrier?->get('producer', 'unknown'),
589-
'messaging.destination.name' => $carrier?->get('destination_name') ?: implode(', ', (array) $message->getRoutingKey()),
589+
'messaging.destination.name' => $carrier?->get('destination_name') ?: (empty($message->getRoutingKey()) ? $message->getExchange() : implode(', ', (array) $message->getRoutingKey())),
590590
'messaging.amqp.message.type' => $message->getTypeString(),
591591
'messaging.amqp.message.routing_key' => $message->getRoutingKey(),
592592
'messaging.amqp.message.exchange' => $message->getExchange(),

0 commit comments

Comments
 (0)