airtime_nginx_php7/airtime_mvc/library/php-amqplib/amqp_test.php

<?php

  //AMQP PHP library test

require_once('amqp.inc');

$EXCHANGE = 'test';
$BROKER_HOST   = 'localhost';
$BROKER_PORT   = 5672;
$QUEUE    = 'myqueue';
$USER     ='guest';
$PASSWORD ='guest';

$msg_body = NULL;

try
{
    echo "Creating connection\n";
    $conn = new AMQPConnection($BROKER_HOST, $BROKER_PORT,
                               $USER,
                               $PASSWORD);
    
    echo "Getting channel\n";
    $ch = $conn->channel();
    echo "Requesting access\n";
    $ch->access_request('/data', false, false, true, true);
    
    echo "Declaring exchange\n";
    $ch->exchange_declare($EXCHANGE, 'direct', false, false, false);

    //echo "Declaring queue\n";
    //$ch->queue_declare($QUEUE);

    //echo "Binding queue to exchange\n";
    //$ch->queue_bind($QUEUE, $EXCHANGE);

    echo "Creating message\n";
    $msg = new AMQPMessage($msg_body, array('content_type' => 'text/plain'));
    
    echo "Publishing message\n";
    $ch->basic_publish($msg, $EXCHANGE, $QUEUE);
    //$ch->basic_publish($msg, $EXCHANGE);
    
    echo "Closing channel\n";
    $ch->close();
    echo "Closing connection\n";
    $conn->close();
    echo "Done.\n";
} catch (Exception $e) {
    echo 'Caught exception: ',  $e->getMessage();
    echo "\nTrace:\n" . $e->getTraceAsString();
}
?>