The message bus is accessible via its interface and within the controllers

Author: sroze

src/Symfony/Bundle/FrameworkBundle/Controller/AbstractController.php

@@ -18,6 +18,7 @@
 use Symfony\Component\HttpFoundation\RequestStack;
 use Symfony\Component\HttpFoundation\Session\SessionInterface;
 use Symfony\Component\HttpKernel\HttpKernelInterface;
+use Symfony\Component\Message\MessageBusInterface;
 use Symfony\Component\Routing\RouterInterface;
 use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
 use Symfony\Component\Security\Core\Authorization\AuthorizationCheckerInterface;
@@ -84,6 +85,7 @@ public static function getSubscribedServices()
             'security.token_storage' => '?'.TokenStorageInterface::class,
             'security.csrf.token_manager' => '?'.CsrfTokenManagerInterface::class,
             'parameter_bag' => '?'.ContainerInterface::class,
+            'message_bus' => '?'.MessageBusInterface::class,
         );
     }
 }

src/Symfony/Bundle/FrameworkBundle/Resources/config/message.xml

@@ -12,6 +12,9 @@
             <argument type="collection" /> <!-- Middlewares -->
         </service>
 
+        <service id="Symfony\Component\Message\MessageBusInterface" alias="message_bus" />
+
+        <!-- Logging -->
         <service id="message.middleware.debug.logging" class="Symfony\Component\Message\Debug\LoggingMiddleware">
             <argument type="service" id="logger" />
 

src/Symfony/Component/Message/Handler/MessageHandlerCollection.php

@@ -37,8 +37,8 @@ public function __construct(array $handlers)
 
     public function __invoke($message)
     {
-        foreach ($this->handlers as $handler) {
-            yield $handler($message);
-        }
+        return array_map(function ($handler) use ($message) {
+            return $handler($message);
+        }, $this->handlers);
     }
 }