Order Update Consumption with AMQP and PHP

gistfile1.aw

$cnn = new AMQPConnection();
$cnn->connect();

// Create a channel
$ch = new AMQPChannel($cnn);

// Declare the events-exchange
$ex = new AMQPExchange($ch);
$ex->setName("events-exchange");
$ex->setType(AMQP_EX_TYPE_TOPIC);
$ex->setFlags(AMQP_DURABLE);
$ex->declare();

$q = new AMQPQueue($ch);
$q->setName('order-event-consumer');
$q->declare();

$q->bind('events-exchange', 'order.*');

function processOrderEvent($envelope, $queue) {
        // do stuff
}

$q->consume("processOrderEvent");