AMQP
PHP Manual

例1 AMQP の例

<?php

// 接続の作成
$cnn = new AMQPConnection();
$cnn->connect();

// 新しい exchange の宣言
$ex = new AMQPExchange($cnn);
$ex->declare('exchange1'AMQP_EX_TYPE_FANOUT);

// 新しいキューの作成
$q = new AMQPQueue($cnn);
$q->declare('queue1');

// exchange 上でキューを routing.key へバインド
$ex->bind('queue1''routing.key');

// ルーティングキーを指定して、メッセージを exchange に公開
$ex->publish('message''routing.key');

// キューからの読み込み
$msg $q->consume();

?>

AMQP
PHP Manual