Description:
------------
---
From manual page: http://www.php.net/amqpqueue.consume#refsect1-amqpqueue.consume-examples
---
<?php

     /* Create a connection using all default credentials: */
     $connection = new AMQPConnection();
     $connection->connect();

     $channel = new AMQPChannel($connection);

     /* Create an exchange. This is optional but you must bind the queue
      * to a valid name or get an error
      */
     $ex = new AMQPExchange( $channel );

     /* Give it a name */
     $ex->setName( 'myExchange' );

     /* Set it as a direct (or point-to-point) type */
     $ex->setType( AMQP_EX_TYPE_DIRECT );

     /* Tell it to delete when empty */
     $ex->setFlags( AMQP_AUTODELETE );

     /* Create the exchange */
     $ex->declare();

     /* create a queue object */
     $queue = new AMQPQueue($channel);

     /* Start the queue up */
     $queue->declare( );

     /* Attach the queue to an exchange */
     $queue->bind( 'myExchange' , 'routing_key' );


     $i = 0;
     function processMessage($envelope, $queue) {
        global $i;
        echo "Message $i: " . $envelope->getBody() . "\n";
        $i++;
        if ($i > 10) {
            // Bail after 10 messages
            return false;
        }
     }

     // Consume messages on queue
     $queue->consume("processMessage");