Skip to content
Snippets Groups Projects
Commit 62f877be authored by davidwhthomas's avatar davidwhthomas Committed by Zach Bimson
Browse files

Issue #3142811 by davidwhthomas: Unable to bind to exchange and send to queue

parent d7c0cc69
No related branches found
No related tags found
1 merge request!46Draft: Issue #3154693 by davidwhthomas: Support exchange and queue different config...
......@@ -180,8 +180,8 @@ abstract class QueueBase {
// Bind the queue to an exchange if defined.
if ($this->queue && !empty($options['routing_keys'])) {
foreach ($options['routing_keys'] as $routingKey) {
list($exchange) = explode('.', $routingKey, 2);
$this->channel->queue_bind($this->name, $exchange, $routingKey);
list($exchange, $key) = explode('.', $routingKey, 2);
$this->channel->queue_bind($this->name, $exchange, $key);
}
}
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment