From b4b3830eb36091e09139fbd2dbba9d9ec13d0eec Mon Sep 17 00:00:00 2001 From: Chimdi Azubuike Date: Tue, 4 Aug 2015 07:16:51 -0700 Subject: [PATCH] removed author tags --- php-amqp/README.md | 0 php-amqp/emit_log.php | 5 --- php-amqp/emit_log_direct.php | 5 --- php-amqp/emit_log_topic.php | 5 --- php-amqp/new_task.php | 4 --- php-amqp/receive.php | 5 +-- php-amqp/receive_log_topic.php | 5 --- php-amqp/receive_logs.php | 6 +--- php-amqp/receive_logs_direct.php | 5 --- php-amqp/receive_logs_topic.php | 54 ++++++++++++++++++++++++++++++++ php-amqp/rpc_client.php | 6 +--- php-amqp/rpc_server.php | 6 +--- php-amqp/send.php | 5 +-- php-amqp/worker.php | 5 +-- 14 files changed, 60 insertions(+), 56 deletions(-) create mode 100644 php-amqp/README.md create mode 100644 php-amqp/receive_logs_topic.php diff --git a/php-amqp/README.md b/php-amqp/README.md new file mode 100644 index 0000000..e69de29 diff --git a/php-amqp/emit_log.php b/php-amqp/emit_log.php index 2df7b8c..51f1f98 100644 --- a/php-amqp/emit_log.php +++ b/php-amqp/emit_log.php @@ -1,9 +1,4 @@ -#!/usr/bin/env php -*/ //Establish connection to AMQP $connection = new AMQPConnection(); diff --git a/php-amqp/emit_log_direct.php b/php-amqp/emit_log_direct.php index 04bbf9c..9c3a978 100644 --- a/php-amqp/emit_log_direct.php +++ b/php-amqp/emit_log_direct.php @@ -1,9 +1,4 @@ -#!/usr/bin/env php - */ //Establish connection to AMQP $connection = new AMQPConnection(); diff --git a/php-amqp/emit_log_topic.php b/php-amqp/emit_log_topic.php index 82e1149..19c343b 100644 --- a/php-amqp/emit_log_topic.php +++ b/php-amqp/emit_log_topic.php @@ -1,9 +1,4 @@ -#!/usr/bin/env php - */ //Establish connection to AMQP $connection = new AMQPConnection(); diff --git a/php-amqp/new_task.php b/php-amqp/new_task.php index 411da55..904acdd 100644 --- a/php-amqp/new_task.php +++ b/php-amqp/new_task.php @@ -1,8 +1,4 @@ -#!/usr/bin/env php -*/ //Establish connection to AMQP $connection = new AMQPConnection(); diff --git a/php-amqp/receive.php b/php-amqp/receive.php index 0d1c353..7715e7a 100644 --- a/php-amqp/receive.php +++ b/php-amqp/receive.php @@ -1,8 +1,5 @@ -#!/usr/bin/env php -*/ + //Establish connection AMQP $connection = new AMQPConnection(); diff --git a/php-amqp/receive_log_topic.php b/php-amqp/receive_log_topic.php index 7c46a49..58db07a 100644 --- a/php-amqp/receive_log_topic.php +++ b/php-amqp/receive_log_topic.php @@ -1,9 +1,4 @@ -#!/usr/bin/env php - */ //Establish connection to AMQP $connection = new AMQPConnection(); diff --git a/php-amqp/receive_logs.php b/php-amqp/receive_logs.php index 8f6c63a..e1a08cd 100644 --- a/php-amqp/receive_logs.php +++ b/php-amqp/receive_logs.php @@ -1,9 +1,5 @@ -#!/usr/bin/env php - */ + //Establish connection to AMQP $connection = new AMQPConnection(); diff --git a/php-amqp/receive_logs_direct.php b/php-amqp/receive_logs_direct.php index 5352b22..65c1fb1 100644 --- a/php-amqp/receive_logs_direct.php +++ b/php-amqp/receive_logs_direct.php @@ -1,9 +1,4 @@ -#!/usr/bin/env php - */ //Establish Connection $connection = new AMQPConnection(); diff --git a/php-amqp/receive_logs_topic.php b/php-amqp/receive_logs_topic.php new file mode 100644 index 0000000..2fdd5ef --- /dev/null +++ b/php-amqp/receive_logs_topic.php @@ -0,0 +1,54 @@ +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); +} diff --git a/php-amqp/rpc_client.php b/php-amqp/rpc_client.php index c438023..622fbf7 100644 --- a/php-amqp/rpc_client.php +++ b/php-amqp/rpc_client.php @@ -1,9 +1,5 @@ -#!/usr/bin/env php - */ + class FibonacciRpcClient { private $connection; diff --git a/php-amqp/rpc_server.php b/php-amqp/rpc_server.php index b4d1e78..6a948a5 100644 --- a/php-amqp/rpc_server.php +++ b/php-amqp/rpc_server.php @@ -1,9 +1,5 @@ -#!/usr/bin/env php - */ + function fib($n) { if($n == 0) diff --git a/php-amqp/send.php b/php-amqp/send.php index ec55faf..f0f1a92 100644 --- a/php-amqp/send.php +++ b/php-amqp/send.php @@ -1,8 +1,5 @@ -#!/usr/bin/env php -*/ + //Establish connection to AMQP $connection = new AMQPConnection(); diff --git a/php-amqp/worker.php b/php-amqp/worker.php index 69f324a..377c81f 100644 --- a/php-amqp/worker.php +++ b/php-amqp/worker.php @@ -1,8 +1,5 @@ -#!/usr/bin/env php -*/ + //Establish connection AMQP $connection = new AMQPConnection();