diff --git a/reference/amqp/examples.xml b/reference/amqp/examples.xml index 066258598a..08e4c22f01 100644 --- a/reference/amqp/examples.xml +++ b/reference/amqp/examples.xml @@ -18,8 +18,8 @@ $ex = new AMQPExchange($cnn); $ex->declare('exchange1', AMQP_EX_TYPE_FANOUT); // Create a new queue -$q = new AMQPQueue($cnn, 'queue1'); -$q->declare(); +$q = new AMQPQueue($cnn); +$q->declare('queue1'); // Bind it on the exchange to routing.key $ex->bind('queue1', 'routing.key'); @@ -28,7 +28,7 @@ $ex->bind('queue1', 'routing.key'); $ex->publish('message', 'routing.key'); // Read from the queue -$msg = $queue->consume(1); +$msg = $q->consume(); ?> ]]>