mareksuscak · September 11, 2019 22:36 · Sep 11, 2019 · Sep 11, 2019 · Sep 11, 2019
diff --git a/messenger.yaml b/messenger.yaml
@@ -2,15 +2,16 @@ framework:
     messenger:
         # ...
 
-        default_bus: messenger.bus.default
+        default_bus: command.bus
         buses:
-            # Message producer bus (default)
-            messenger.bus.default:
-                # Override the bus name that should receive and handle messages (bus name: consumer.bus)
-                - App\Messenger\Middleware\AddConsumerBusNameStampMiddleware
+            command.bus:
+                # Will be run in the producer context (message sender)
+                middleware:
+                    # Override the bus name that should receive and handle messages (bus name: consumer.bus)
+                    - App\Messenger\Middleware\AddConsumerBusNameStampMiddleware
 
-            # Message consumer bus
             consumer.bus:
+                # Will be run in the consumer context (message receiver -> worker)
                 middleware:
                     - doctrine_ping_connection
                     - doctrine_transaction
diff --git a/AddConsumerBusNameStampMiddleware.php b/AddConsumerBusNameStampMiddleware.php
@@ -0,0 +1,21 @@
+<?php
+
+namespace App\Messenger\Middleware;
+
+use Symfony\Component\Messenger\Middleware\MiddlewareInterface;
+use Symfony\Component\Messenger\Middleware\StackInterface;
+use Symfony\Component\Messenger\Envelope;
+use Symfony\Component\Messenger\Stamp\BusNameStamp;
+
+# This is sort of a workaround, read more here:
+# https://github.com/symfony/symfony/issues/32436#issuecomment-530565499
+
+final class AddConsumerBusNameStampMiddleware implements MiddlewareInterface
+{
+    public function handle(Envelope $envelope, StackInterface $stack): Envelope
+    {
+        $envelope = $envelope->with(new BusNameStamp('consumer.bus'));
+
+        return $stack->next()->handle($envelope, $stack);
+    }
+}
diff --git a/messenger.yaml b/messenger.yaml
@@ -0,0 +1,16 @@
+framework:
+    messenger:
+        # ...
+
+        default_bus: messenger.bus.default
+        buses:
+            # Message producer bus (default)
+            messenger.bus.default:
+                # Override the bus name that should receive and handle messages (bus name: consumer.bus)
+                - App\Messenger\Middleware\AddConsumerBusNameStampMiddleware
+
+            # Message consumer bus
+            consumer.bus:
+                middleware:
+                    - doctrine_ping_connection
+                    - doctrine_transaction