Как в RabbitMQ и PHP вернуть таск в очередь?

Question

[John Doe]

Как можно вернуть сообещние обратно в очередь если результат обработки меня не устроил. Находил только информацию про message acknowledgments но думаю что это мне не подходит. Мне нужно чтобы если в результате обработки я получаю параметр RETRY сообщение передобавлялось в очередь. А далее этот воркер или другой подхватывает его снова и пытается обработать.

Напримр так:

<?php
use PhpAmqpLib\Connection\AMQPStreamConnection;

echo ' [*] Waiting for messages. To exit press CTRL+C', "\n";

$connection = new AMQPStreamConnection($AMQP);
$channel = $connection->channel();

$channel->queue_declare('test', false, false, false, false);

$callback = function($msg) {
  $condition = json_decode($msg->body);

  if (!$condition) {
    # return to the queue
  }
};

$channel->basic_consume('test', '', false, true, false, false, $callback);

while(count($channel->callbacks)) {
  $channel->wait();
}

$channel->close();
$connection->close();
?>

Answer 1

[John Doe]

Решение оказалось проще чем я думал, оказывается задача стояла не про RabbitMQ конкретно, а про область видимости переменных. Если кому интересно решение, вот:

<?php
use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;

echo ' [*] Waiting for messages. To exit press CTRL+C', "\n";

$connection = new AMQPStreamConnection($AMQP);
$channel = $connection->channel();

$channel->queue_declare('test', false, false, false, false);

$callback = function($msg) {
  global $channel;

  $condition = json_decode($msg->body);

  if (!$condition) {
    $msg = new AMQPMessage(json_encode(array(
      'condition' => false
    )));

    $channel->basic_publish($msg, '', 'test');
  }
};

$channel->basic_consume('test', '', false, true, false, false, $callback);

while(count($channel->callbacks)) {
  $channel->wait();
}

$channel->close();
$connection->close();
?>

Comments

[iRedds]

Ужас. Если уж используешь анонимную функцию, то смотри на конструкцию function(..) use (..) {}

function ($msg) use ($channel) {
}

[John Doe]

iRedds, спасибо так тоже работает!

Answer 2

[Радость моя]

$callback = function($msg) {
    global $channel;

еще можно так:

$callback = function($msg) use ($channel) {
    ...