diff --git a/src/Symfony/Component/Messenger/Transport/AmqpExt/Connection.php b/src/Symfony/Component/Messenger/Transport/AmqpExt/Connection.php index 6f50bd76d5e65..5be6f70723b5e 100644 --- a/src/Symfony/Component/Messenger/Transport/AmqpExt/Connection.php +++ b/src/Symfony/Component/Messenger/Transport/AmqpExt/Connection.php @@ -98,7 +98,7 @@ public function publish(string $body, array $headers = array()): void $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)); } /**