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(