Python examples ported to PHP

.gitignore

@@ -0,0 +1 @@
+php/lib/php-amqplib

php/README.md

@@ -0,0 +1,25 @@
+# RabbitMQ - PHP Examples #
+
+## Requirements ##
+
+To run the examples you need:
+
+- A running RabbitMQ server
+- PHP 5.3
+- php-amqplib
+
+## Setup ##
+
+To get the php-amqplib library execute the following command inside the present folder:
+
+		$ git clone http://github.com/tnc/php-amqplib.git lib/php-amqplib
+
+## Running the Examples ##
+
+To run the examples do in one Terminal:
+
+		$ php send.php some message to send
+
+Then in another Terminal try:
+
+		$ php receive.php

php/config/config.php

@@ -0,0 +1,8 @@
+<?php
+// define('AMQP_DEBUG', true); //enable if you want to see logs.
+
+define('HOST', 'localhost');
+define('PORT', 5672);
+define('USER', 'guest');
+define('PASS', 'guest');
+define('VHOST', '/');

php/emit_log.php

@@ -0,0 +1,21 @@
+<?php
+
+require_once(__DIR__ . '/lib/php-amqplib/amqp.inc');
+include_once(__DIR__ . '/config/config.php');
+
+$connection = new AMQPConnection(HOST, PORT, USER, PASS, VHOST);
+$channel = $connection->channel();
+$channel->exchange_declare('logs', 'fanout');
+
+$data = implode(' ', array_slice($argv, 1));
+if(empty($data)) $data = "info: Hello World!";
+$msg = new AMQPMessage($data);
+
+$channel->basic_publish($msg, 'logs');
+
+echo " [x] Sent ", $data, "\n";
+
+$channel->close();
+$connection->close();
+
+?>

php/new_task.php

@@ -0,0 +1,24 @@
+<?php
+
+require_once(__DIR__ . '/lib/php-amqplib/amqp.inc');
+include_once(__DIR__ . '/config/config.php');
+
+$connection = new AMQPConnection(HOST, PORT, USER, PASS, VHOST);
+$channel = $connection->channel();
+
+$channel->queue_declare('task_queue', false, true);
+
+$data = implode(' ', array_slice($argv, 1));
+if(empty($data)) $data = "Hello World!";
+$msg = new AMQPMessage($data, 
+                        array('delivery_mode' => 2) # make message persistent
+                      );
+
+$channel->basic_publish($msg, '', 'task_queue');
+
+echo " [x] Sent ", $data, "\n";
+
+$channel->close();
+$connection->close();
+
+?>

php/receive.php

@@ -0,0 +1,26 @@
+<?php
+
+require_once(__DIR__ . '/lib/php-amqplib/amqp.inc');
+include_once(__DIR__ . '/config/config.php');
+
+$connection = new AMQPConnection(HOST, PORT, USER, PASS, VHOST);
+$channel = $connection->channel();
+
+$channel->queue_declare('test');
+
+echo ' [*] Waiting for messages. To exit press CTRL+C', "\n";
+
+$callback = function($msg){
+  echo " [x] Received ", $msg->body, "\n";
+};
+
+$channel->basic_consume('test', 'consumer_tag', false, true, false, false, $callback);
+
+while(count($channel->callbacks)) {
+    $channel->wait();
+}
+
+$channel->close();
+$connection->close();
+
+?>

php/receive_logs.php

@@ -0,0 +1,29 @@
+<?php
+
+require_once(__DIR__ . '/lib/php-amqplib/amqp.inc');
+include_once(__DIR__ . '/config/config.php');
+
+$connection = new AMQPConnection(HOST, PORT, USER, PASS, VHOST);
+$channel = $connection->channel();
+$channel->exchange_declare('logs', 'fanout');
+
+list($queue_name, ,) = $channel->queue_declare();
+
+$channel->queue_bind($queue_name, 'logs');
+
+echo ' [*] Waiting for logs. To exit press CTRL+C', "\n";
+
+$callback = function($msg){
+  echo $msg->body, "\n";
+};
+
+$channel->basic_consume($queue_name, 'consumer_tag', false, true, false, false, $callback);
+
+while(count($channel->callbacks)) {
+    $channel->wait();
+}
+
+$channel->close();
+$connection->close();
+
+?>

php/send.php

@@ -0,0 +1,20 @@
+<?php
+
+require_once(__DIR__ . '/lib/php-amqplib/amqp.inc');
+include_once(__DIR__ . '/config/config.php');
+
+$connection = new AMQPConnection(HOST, PORT, USER, PASS, VHOST);
+$channel = $connection->channel();
+
+$channel->queue_declare('test');
+
+$msg = new AMQPMessage('Hello World!');
+
+$channel->basic_publish($msg, '', 'test');
+
+echo " [x] Sent 'Hello World!'\n";
+
+$channel->close();
+$connection->close();
+
+?>

php/worker.php

@@ -0,0 +1,30 @@
+<?php
+
+require_once(__DIR__ . '/lib/php-amqplib/amqp.inc');
+include_once(__DIR__ . '/config/config.php');
+
+$connection = new AMQPConnection(HOST, PORT, USER, PASS, VHOST);
+$channel = $connection->channel();
+
+$channel->queue_declare('task_queue', false, true);
+
+echo ' [*] Waiting for messages. To exit press CTRL+C', "\n";
+
+$callback = function($msg){
+  echo " [x] Received ", $msg->body, "\n";
+  sleep(substr_count($msg->body, '.'));
+  echo " [x] Done", "\n";
+  $msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']);
+};
+
+$channel->basic_qos(null, 1, null);
+$channel->basic_consume('task_queue', 'consumer_tag', false, false, false, false, $callback);
+
+while(count($channel->callbacks)) {
+    $channel->wait();
+}
+
+$channel->close();
+$connection->close();
+
+?>