例1 AMQP の例
<?php
// 接続の作成
$cnn = new AMQPConnection();
$cnn->connect();
// 新しいチャネルの作成
$ch = new AMQPChannel($cnn);
// 新しい exchange の宣言
$ex = new AMQPExchange($ch);
$ex->declare('exchange1', AMQP_EX_TYPE_FANOUT);
// 新しいキューの作成
$q = new AMQPQueue($ch);
$q->declare('queue1');
// exchange 上でキューを routing.key へバインド
$ex->bind('queue1', 'routing.key');
// ルーティングキーを指定して、メッセージを exchange に公開
$ex->publish('message', 'routing.key');
// キューからの読み込み
$msg = $q->consume();
?>