54 lines
1.3 KiB
PHP
54 lines
1.3 KiB
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();
|
|
}
|
|
?>
|