Exemple #1 AMQP - Example
<?php
// Création d'une connexion
$cnn = new AMQPConnection();
$cnn->connect();
// Crée un canal
$ch = new AMQPChannel($cnn);
// Déclare un nouvel échange
$ex = new AMQPExchange($ch);
$ex->declare('exchange1', AMQP_EX_TYPE_FANOUT);
// Création d'une nouvelle file d'attente
$q = new AMQPQueue($ch);
$q->declare('queue1');
// On la lie sur l'échange avec routing.key
$ex->bind('queue1', 'routing.key');
// Publie un message sur l'échange en utilisant une clé
$ex->publish('message', 'routing.key');
// Lecture de la file d'attente
$msg = $q->consume();
?>