diff --git a/src/EventListener/MessengerProfilerListener.php b/src/EventListener/MessengerProfilerListener.php index 8b91e32..b8905e8 100644 --- a/src/EventListener/MessengerProfilerListener.php +++ b/src/EventListener/MessengerProfilerListener.php @@ -34,7 +34,7 @@ public static function getSubscribedEvents() public function onInvoke(WorkerMessageReceivedEvent $event): void { - $transactionName = \get_class($event->getEnvelope()->getMessage()); + $transactionName = str_replace('\\', '/', \get_class($event->getEnvelope()->getMessage())); $this->profiler->stop(); $this->profiler->start($transactionName, 'messenger'); diff --git a/src/Messenger/ProfilerMiddleware.php b/src/Messenger/ProfilerMiddleware.php old mode 100755 new mode 100644 index 3bd1be0..5088712 --- a/src/Messenger/ProfilerMiddleware.php +++ b/src/Messenger/ProfilerMiddleware.php @@ -29,7 +29,7 @@ public function __construct(ProfilerInterface $profiler, ?RequestStack $requestS public function handle(Envelope $envelope, StackInterface $stack): Envelope { - $transactionName = \get_class($envelope->getMessage()); + $transactionName = str_replace('\\', '/', \get_class($envelope->getMessage())); $skip = false; if (null !== $this->requestStack diff --git a/src/Profiler/SymfonyProfiler.php b/src/Profiler/SymfonyProfiler.php old mode 100755 new mode 100644 index 5951315..8d1c6e8 --- a/src/Profiler/SymfonyProfiler.php +++ b/src/Profiler/SymfonyProfiler.php @@ -45,6 +45,7 @@ public function start(string $name, ?string $kind = null): void $kind = 'custom'; } + $name = str_replace('\\', '/', $name); $uri = sprintf('http://%s/%s', $kind, $name); $this->request = Request::create($uri, $kind);