note 109772 added to amqp.examples
| From: | bradyjvitrano at gmail dot com | Date: | Sat, 18 Aug 2012 17:41:06 +0000 |
| Subject: | note 109772 added to amqp.examples | ||
| Groups: | php.notes | ||
| Request: | Send a blank email to php-notes+get-190131@lists.php.net to get a copy of this message | ||
This example assumes no previous queue or exchange has been declared.
Send File
<?php
/**
* Filename: send.php
* Purpose:
* Send messages to RabbitMQ server using AMQP extension
* Exchange Name: exchange1
* Exchange Type: fanout
* Queue Name: queue1
*/
$connection = new AMQPConnection();
$connection->connect();
if (!$connection->isConnected()) {
die('Not connected :(' . PHP_EOL);
}
// Open Channel
$channel = new AMQPChannel($connection);
// Declare exchange
$exchange = new AMQPExchange($channel);
$exchange->setName('exchange1');
$exchange->setType('fanout');
$exchange->declare();
// Create Queue
$queue = new AMQPQueue($channel);
$queue->setName('queue1');
$queue->declare();
$message = $exchange->publish('Custom Message (ts): '.time(), 'key1');
if (!$message) {
echo 'Message not sent', PHP_EOL;
} else {
echo 'Message sent!', PHP_EOL;
}
?>
Receive File
<?php
/**
* Filename: receive.php
* Purpose:
* Receive messages from RabbitMQ server using AMQP extension
* Exchange Name: exchange1
* Exchange Type: fanout
* Queue Name: queue1
*/
$connection = new AMQPConnection();
$connection->connect();
if (!$connection->isConnected()) {
die('Not connected :('. PHP_EOL);
}
// Open channel
$channel = new AMQPChannel($connection);
// Open Queue and bind to exchange
$queue = new AMQPQueue($channel);
$queue->setName('queue1');
$queue->bind('exchange1', 'key1');
$queue->declare();
// Prevent message redelivery with AMQP_AUTOACK param
while ($envelope = $queue->get(AMQP_AUTOACK)) {
echo ($envelope->isRedelivery()) ? 'Redelivery' : 'New Message';
echo PHP_EOL;
echo $envelope->getBody(), PHP_EOL;
}
?>
Test It
$ php -f send.php
$ php -f receive.php
----
Server IP: 69.147.83.197
Probable Submitter: 67.66.69.161
----
Manual Page -- http://www.php.net/manual/en/amqp.examples.php
Edit -- https://master.php.net/note/edit/109772
Del: integrated -- https://master.php.net/note/delete/109772/integrated
Del: useless -- https://master.php.net/note/delete/109772/useless
Del: bad code -- https://master.php.net/note/delete/109772/bad+code
Del: spam -- https://master.php.net/note/delete/109772/spam
Del: non-english -- https://master.php.net/note/delete/109772/non-english
Del: in docs -- https://master.php.net/note/delete/109772/in+docs
Del: other reasons-- https://master.php.net/note/delete/109772
Reject -- https://master.php.net/note/reject/109772
Search -- https://master.php.net/manage/user-notes.php