[Messenger] send using the routing_key for AMQP transport

2018-10-22 22:39:08 +02:00 · 2018-10-22 22:39:08 +02:00 · 666d2d962b
commit 666d2d962b
parent 3dda3cc5b3
1 changed files with 1 additions and 1 deletions
--- a/src/Symfony/Component/Messenger/Transport/AmqpExt/Connection.php
+++ b/src/Symfony/Component/Messenger/Transport/AmqpExt/Connection.php
@ -98,7 +98,7 @@ class Connection
            $this->setup();
        }

-        $this->exchange()->publish($body, null, AMQP_NOPARAM, array('headers' => $headers));
+        $this->exchange()->publish($body, $this->queueConfiguration['routing_key'] ?? null, AMQP_NOPARAM, array('headers' => $headers));
    }

    /**