Exemples
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(); ?>