[Messenger] send using the routing_key for AMQP transport

nicolas-grekas · nicolas-grekas · commit 1ebec2978ea7 · 2018-10-25T11:24:34.000+02:00
diff --git a/Transport/AmqpExt/Connection.php b/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));
     }
 
     /**

Original file line number	Diff line number	Diff line change
`@@ -98,7 +98,7 @@ public function publish(string $body, array $headers = array()): void`
`98`	`98`	`$this->setup();`
`99`	`99`	`}`
`100`	`100`
`101`		`- $this->exchange()->publish($body, null, AMQP_NOPARAM, array('headers' => $headers));`
	`101`	`+ $this->exchange()->publish($body, $this->queueConfiguration['routing_key'] ?? null, AMQP_NOPARAM, array('headers' => $headers));`
`102`	`102`	`}`
`103`	`103`
`104`	`104`	`/**`