PHP: use a more modern way to check if a channel is open

References rabbitmq/rabbitmq-website#1162
rabbitmq · Apr 6, 2021 · 9e71f57 · 9e71f57
1 parent c654c2b
commit 9e71f57
Show file tree

Hide file tree

Showing 7 changed files with 7 additions and 7 deletions.
diff --git a/php/composer.json b/php/composer.json
@@ -1,5 +1,5 @@
 {
     "require": {
-        "php-amqplib/php-amqplib": ">=v2.12.1"
+        "php-amqplib/php-amqplib": ">=3.0"
     }
 }
diff --git a/php/receive.php b/php/receive.php
@@ -16,7 +16,7 @@
 
 $channel->basic_consume('hello', '', false, true, false, false, $callback);
 
-while ($channel->is_consuming()) {
+while ($channel->is_open()) {
     $channel->wait();
 }
 

diff --git a/php/receive_logs.php b/php/receive_logs.php
@@ -20,7 +20,7 @@
 
 $channel->basic_consume($queue_name, '', false, true, false, false, $callback);
 
-while ($channel->is_consuming()) {
+while ($channel->is_open()) {
     $channel->wait();
 }
 

diff --git a/php/receive_logs_direct.php b/php/receive_logs_direct.php
@@ -28,7 +28,7 @@
 
 $channel->basic_consume($queue_name, '', false, true, false, false, $callback);
 
-while ($channel->is_consuming()) {
+while ($channel->is_open()) {
     $channel->wait();
 }
 

diff --git a/php/receive_logs_topic.php b/php/receive_logs_topic.php
@@ -28,7 +28,7 @@
 
 $channel->basic_consume($queue_name, '', false, true, false, false, $callback);
 
-while ($channel->is_consuming()) {
+while ($channel->is_open()) {
     $channel->wait();
 }
 

diff --git a/php/rpc_server.php b/php/rpc_server.php
@@ -41,7 +41,7 @@ function fib($n)
 $channel->basic_qos(null, 1, null);
 $channel->basic_consume('rpc_queue', '', false, false, false, false, $callback);
 
-while ($channel->is_consuming()) {
+while ($channel->is_open()) {
     $channel->wait();
 }
 

diff --git a/php/worker.php b/php/worker.php
@@ -20,7 +20,7 @@
 $channel->basic_qos(null, 1, null);
 $channel->basic_consume('task_queue', '', false, false, false, false, $callback);
 
-while ($channel->is_consuming()) {
+while ($channel->is_open()) {
     $channel->wait();
 }