airtime_nginx_php7/airtime_mvc/library/php-amqplib/demo/amqp_consumer.php

#!/usr/bin/php
<?php
/**
 * Repeatedly receive messages from queue until it receives a message with
 * 'quit' as the body.
 *
 * @author Sean Murphy<sean@iamseanmurphy.com>
 */
 
require_once('../amqp.inc');

$HOST = 'localhost';
$PORT = 5672;
$USER = 'guest';
$PASS = 'guest';
$VHOST = '/';
$EXCHANGE = 'airtime-schedule';
$QUEUE = 'msgs';
$CONSUMER_TAG = 'consumer';

$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, 'direct', false, true);
$ch->queue_bind($QUEUE, $EXCHANGE);

function process_message($msg) {
    global $ch, $CONSUMER_TAG;
    
    echo "\n--------\n";
    echo $msg->body;
    echo "\n--------\n";
    
    $ch->basic_ack($msg->delivery_info['delivery_tag']);
    
    // Cancel callback
    if ($msg->body === 'quit') {
        $ch->basic_cancel($CONSUMER_TAG);
    }
}

$ch->basic_consume($QUEUE, $CONSUMER_TAG, false, false, false, false, 'process_message');

// Loop as long as the channel has callbacks registered
echo "Waiting for messages...\n";
while(count($ch->callbacks)) {
    $ch->wait();
}

$ch->close();
$conn->close();
?>