Final touches to third tutorial examples.

majek · majek · commit f10c7468882f · 2010-11-23T13:32:23.000Z
diff --git a/php/emit_log.php b/php/emit_log.php
@@ -1,11 +1,12 @@
 <?php
 
 require_once(__DIR__ . '/lib/php-amqplib/amqp.inc');
-include_once(__DIR__ . '/config/config.php');
 
-$connection = new AMQPConnection(HOST, PORT, USER, PASS, VHOST);
+$connection = new AMQPConnection('localhost', 5672, 'guest', 'guest');
 $channel = $connection->channel();
-$channel->exchange_declare('logs', 'fanout');
+
+
+$channel->exchange_declare('logs', 'fanout', false, false, false);
 
 $data = implode(' ', array_slice($argv, 1));
 if(empty($data)) $data = "info: Hello World!";
diff --git a/php/receive_logs.php b/php/receive_logs.php
@@ -1,11 +1,12 @@
 <?php
 
 require_once(__DIR__ . '/lib/php-amqplib/amqp.inc');
-include_once(__DIR__ . '/config/config.php');
 
-$connection = new AMQPConnection(HOST, PORT, USER, PASS, VHOST);
+$connection = new AMQPConnection('localhost', 5672, 'guest', 'guest');
 $channel = $connection->channel();
-$channel->exchange_declare('logs', 'fanout');
+
+
+$channel->exchange_declare('logs', 'fanout', false, false, false);
 
 list($queue_name, ,) = $channel->queue_declare();
 
@@ -14,11 +15,11 @@
 echo ' [*] Waiting for logs. To exit press CTRL+C', "\n";
 
 $callback = function($msg){
-  echo $msg->body, "\n";
+  echo ' [x] ', $msg->body, "\n";
 };
 
-$channel->basic_consume($queue_name, 'consumer_tag', false, true, false, false, $callback);
-  
+$channel->basic_consume($queue_name, '', false, true, false, false, $callback);
+
 while(count($channel->callbacks)) {
     $channel->wait();
 }
