Ejemplo #1 Ejemplo de AMQP
<?php
// Crear una conexión
$cnn = new AMQPConnection();
$cnn->connect();
// Crear un canal
$ch = new AMQPChannel($cnn);
// Declara un nuevo intercambio
$ex = new AMQPExchange($ch);
$ex->declare('exchange1', AMQP_EX_TYPE_FANOUT);
// Crear una nueva cola
$q = new AMQPQueue($ch);
$q->declare('queue1');
// Atarlo en el intercambio a routing.key
$ex->bind('queue1', 'routing.key');
// Publicar un mensaje en el intercambio con una clave de ruta
$ex->publish('message', 'routing.key');
// Leer de la cola
$msg = $q->consume();
?>