symfony
diff --git a/‎src/Symfony/Component/Messenger/DependencyInjection/MessengerPass.php
Lines changed: 4 additions & 8 deletions b/‎src/Symfony/Component/Messenger/DependencyInjection/MessengerPass.php
Lines changed: 4 additions & 8 deletions
@@ -30,17 +30,13 @@
  */
 class MessengerPass implements CompilerPassInterface
 {
-    private $handlerTag = 'messenger.message_handler';
-    private $busTag = 'messenger.bus';
-    private $receiverTag = 'messenger.receiver';
-
     /**
      * {@inheritdoc}
      */
     public function process(ContainerBuilder $container)
     {
         $busIds = [];
-        foreach ($container->findTaggedServiceIds($this->busTag) as $busId => $tags) {
+        foreach ($container->findTaggedServiceIds('messenger.bus') as $busId => $tags) {
             $busIds[] = $busId;
             if ($container->hasParameter($busMiddlewareParameter = $busId.'.middleware')) {
                 $this->registerBusMiddleware($container, $busId, $container->getParameter($busMiddlewareParameter));
@@ -65,10 +61,10 @@ private function registerHandlers(ContainerBuilder $container, array $busIds)
         $handlersByBusAndMessage = [];
         $handlerToOriginalServiceIdMapping = [];
 
-        foreach ($container->findTaggedServiceIds($this->handlerTag, true) as $serviceId => $tags) {
+        foreach ($container->findTaggedServiceIds('messenger.message_handler', true) as $serviceId => $tags) {
             foreach ($tags as $tag) {
                 if (isset($tag['bus']) && !\in_array($tag['bus'], $busIds, true)) {
-                    throw new RuntimeException(sprintf('Invalid handler service "%s": bus "%s" specified on the tag "%s" does not exist (known ones are: "%s").', $serviceId, $tag['bus'], $this->handlerTag, implode('", "', $busIds)));
+                    throw new RuntimeException(sprintf('Invalid handler service "%s": bus "%s" specified on the tag "messenger.message_handler" does not exist (known ones are: "%s").', $serviceId, $tag['bus'], implode('", "', $busIds)));
                 }
 
                 $className = $this->getServiceClass($container, $serviceId);
@@ -253,7 +249,7 @@ private function registerReceivers(ContainerBuilder $container, array $busIds)
             }
         }
 
-        foreach ($container->findTaggedServiceIds($this->receiverTag) as $id => $tags) {
+        foreach ($container->findTaggedServiceIds('messenger.receiver') as $id => $tags) {
             $receiverClass = $this->getServiceClass($container, $id);
             if (!is_subclass_of($receiverClass, ReceiverInterface::class)) {
                 throw new RuntimeException(sprintf('Invalid receiver "%s": class "%s" must implement interface "%s".', $id, $receiverClass, ReceiverInterface::class));