rabbitmq client端

$conn = new AMQPConnection($HOST, $PORT, $USER, $PASS);
$ch = $conn->channel();
$ch->access_request($VHOST, false, false, true, true);

$ch->queue_declare($QUEUE);
$ch->exchange_declare($EXCHANGE, 'topic', false, false, false);
$ch->queue_bind($QUEUE, $EXCHANGE, 'usa.#');