From 4b349374d58362472a274fb26f94b97483966c69 Mon Sep 17 00:00:00 2001 From: Marek Mazur Date: Mon, 1 Feb 2016 10:40:41 +0100 Subject: [PATCH] fix exchange routing --- amqplibconnector.php | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/amqplibconnector.php b/amqplibconnector.php index 6ea88af..da2d040 100644 --- a/amqplibconnector.php +++ b/amqplibconnector.php @@ -106,7 +106,8 @@ function PostToExchange($connection, $details, $task, $params) $ch->queue_bind( $details['binding'], /* queue name - "celery" */ - $details['exchange'] /* exchange name - "celery" */ + $details['exchange']. /* exchange name - "celery" */ + $details['routing_key'] ); $msg = new AMQPMessage(