removed author tags

php-amqp/emit_log.php

@@ -1,9 +1,4 @@
-#!/usr/bin/env php
 <?php
-/**
- emit_log.php
- @author Chimdi Azubuike <me@chimdi.com>
-*/
 
 //Establish connection to AMQP
 $connection = new AMQPConnection();

php-amqp/emit_log_direct.php

@@ -1,9 +1,4 @@
-#!/usr/bin/env php
 <?php
-/**
- emit_log_direct.php 
- @author: Chimdi Azubuike <me@chimdi.com>
- */
 
 //Establish connection to AMQP
 $connection = new AMQPConnection();

php-amqp/emit_log_topic.php

@@ -1,9 +1,4 @@
-#!/usr/bin/env php
 <?php
-/**
- emit_log_topic.php 
- @author: Chimdi Azubuike <me@chimdi.com>
- */
 
 //Establish connection to AMQP
 $connection = new AMQPConnection();

php-amqp/new_task.php

@@ -1,8 +1,4 @@
-#!/usr/bin/env php
 <?php
-/**
- @author Chimdi Azubuike <me@chimdi.com>
-*/
 
 //Establish connection to AMQP
 $connection = new AMQPConnection();

php-amqp/receive.php

@@ -1,8 +1,5 @@
-#!/usr/bin/env php
 <?php
-/**
-	@author Chimdi Azubuike <me@chimdi.com>
-*/
+
 
 //Establish connection AMQP
 $connection = new AMQPConnection();

php-amqp/receive_log_topic.php

@@ -1,9 +1,4 @@
-#!/usr/bin/env php
 <?php
-/**
- receive_log_topic.php 
- @author: Chimdi Azubuike <me@chimdi.com>
- */
 
 //Establish connection to AMQP
 $connection = new AMQPConnection();

php-amqp/receive_logs.php

@@ -1,9 +1,5 @@
-#!/usr/bin/env php
 <?php
-/**
-	receive_logs.php 
- 	@author: Chimdi Azubuike <me@chimdi.com>
- */
+
 
 //Establish connection to AMQP
 $connection = new AMQPConnection();

php-amqp/receive_logs_direct.php

@@ -1,9 +1,4 @@
-#!/usr/bin/env php
 <?php
-/**
- receive_logs_direct.php 
- @author: Chimdi Azubuike <me@chimdi.com>
- */
 
 //Establish Connection
 $connection = new AMQPConnection();

php-amqp/receive_logs_topic.php

@@ -0,0 +1,54 @@
+<?php
+
+
+//Establish Connection
+$connection = new AMQPConnection();
+$connection->setHost('127.0.0.1');
+$connection->setLogin('guest');
+$connection->setPassword('guest');
+$connection->connect();
+
+
+//Listen on Channel
+$channel = new AMQPChannel($connection);
+
+	
+$binding_keys = array_slice($argv,1);
+if(empty($binding_keys)) {
+	file_put_contents('php://stderr', "Usage: {$argv[0]} [binding_key]...\n");
+	exit(1);
+}
+
+echo " [*] Waiting for logs. To exit press CTRL+C", PHP_EOL;
+$callback_func = function(AMQPEnvelope $message, AMQPQueue $q) {
+	echo sprintf(" [X] [%s] %s",$message->getRoutingKey(),$message->getBody()), PHP_EOL;
+	$q->nack($message->getDeliveryTag());
+	return true;
+};
+
+
+
+try {
+	//Declare Exchange
+	$exchange_name = 'topic_logs';
+	$exchange = new AMQPExchange($channel);
+	$exchange->setType(AMQP_EX_TYPE_TOPIC);
+	$exchange->setName($exchange_name);
+	$exchange->declareExchange();
+
+
+
+	//Declare Queue
+	$queue = new AMQPQueue($channel);
+	$queue->setFlags(AMQP_EXCLUSIVE);
+	$queue->declareQueue();
+	foreach($binding_keys as $binding_key) {
+		$queue->bind($exchange_name, $binding_key);
+	}
+
+	$queue->consume($callback_func);
+} catch(AMQPQueueException $ex) {
+	print_r($ex);
+} catch(Exception $ex) {
+	print_r($ex);
+}

php-amqp/rpc_client.php

@@ -1,9 +1,5 @@
-#!/usr/bin/env php
 <?php
-/**
- rpc_client.php 
- @author: Chimdi Azubuike <me@chimdi.com>
- */
+
 
 class FibonacciRpcClient {
 	private $connection;

php-amqp/rpc_server.php

@@ -1,9 +1,5 @@
-#!/usr/bin/env php
 <?php
-/**
- rpc_server.php 
- @author: Chimdi Azubuike <me@chimdi.com>
- */
+
 
 function fib($n) {
 	if($n == 0)

php-amqp/send.php

@@ -1,8 +1,5 @@
-#!/usr/bin/env php
 <?php
-/**
-	@author Chimdi Azubuike <me@chimdi.com>
-*/
+
 
 //Establish connection to AMQP
 $connection = new AMQPConnection();

php-amqp/worker.php

@@ -1,8 +1,5 @@
-#!/usr/bin/env php
 <?php
-/**
-	@author Chimdi Azubuike <me@chimdi.com>
-*/
+
 
 //Establish connection AMQP
 $connection = new AMQPConnection();