echo/rabbitmq-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #227 from angyvolin/use-api-instead-of-internal-stuff

Browse Source 
update php tutorials: avoid usage of deprecated/internal stuff
This commit is contained in:
Michael Klishin 2019-07-15 16:23:27 +03:00 committed by GitHub
commit 9ffe0f5cfa
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
6 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
php/receive.php
View File

@ -16,7 +16,7 @@ $callback = function ($msg) {
$channel->basic_consume('hello', '', false, true, false, false, $callback);
while (count($channel->callbacks)) {
while ($channel->is_consuming()) {
$channel->wait();
}

2
php/receive_logs.php
View File

@ -20,7 +20,7 @@ $callback = function ($msg) {
$channel->basic_consume($queue_name, '', false, true, false, false, $callback);
while (count($channel->callbacks)) {
while ($channel->is_consuming()) {
$channel->wait();
}

2
php/receive_logs_direct.php
View File

@ -28,7 +28,7 @@ $callback = function ($msg) {
$channel->basic_consume($queue_name, '', false, true, false, false, $callback);
while (count($channel->callbacks)) {
while ($channel->is_consuming()) {
$channel->wait();
}

2
php/receive_logs_topic.php
View File

@ -28,7 +28,7 @@ $callback = function ($msg) {
$channel->basic_consume($queue_name, '', false, true, false, false, $callback);
while (count($channel->callbacks)) {
while ($channel->is_consuming()) {
$channel->wait();
}

2
php/rpc_server.php
View File

@ -43,7 +43,7 @@ $callback = function ($req) {
$channel->basic_qos(null, 1, null);
$channel->basic_consume('rpc_queue', '', false, false, false, false, $callback);
while (count($channel->callbacks)) {
while ($channel->is_consuming()) {
$channel->wait();
}

2
php/worker.php
View File

@ -20,7 +20,7 @@ $callback = function ($msg) {
$channel->basic_qos(null, 1, null);
$channel->basic_consume('task_queue', '', false, false, false, false, $callback);
while (count($channel->callbacks)) {
while ($channel->is_consuming()) {
$channel->wait();
}