note 109772 deleted from amqp.examples by sobak
| From: | sobak@php.net | Date: | Thu, 24 Nov 2016 20:35:09 +0000 |
| Subject: | note 109772 deleted from amqp.examples by sobak | ||
| References: | 1 | Groups: | php.notes |
| Request: | Send a blank email to php-notes+get-207596@lists.php.net to get a copy of this message | ||
Note Submitter: bradyjvitrano at gmail dot com
----
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