Задать вопрос
rabbit418
@rabbit418
23 yo Designer from Ukraine
php

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

Как можно вернуть сообещние обратно в очередь если результат обработки меня не устроил. Находил только информацию про 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();
?>
  • Вопрос задан
  • 1199 просмотров
Комментировать
Подписаться 1 Оценить Комментировать
Решения вопроса 1
rabbit418
@rabbit418 Автор вопроса
23 yo Designer from Ukraine
Решение оказалось проще чем я думал, оказывается задача стояла не про 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();
?>
Ответ написан
2 комментария
2 комментария
Пригласить эксперта
Ответы на вопрос 1
t-alexashka
@t-alexashka
Сразу пишу legacy код 
$callback = function($msg) {
    global $channel;

еще можно так:
$callback = function($msg) use ($channel) {
    ...
Ответ написан
Комментировать
Комментировать
Ваш ответ на вопрос

Войдите, чтобы написать ответ

Войти через центр авторизации
Похожие вопросы
Вакансии с Хабр Карьеры
PHP Developer
YCLIENTS • Москва
от 200 000 до 350 000 ₽
PHP разработчик
Ведисофт • Екатеринбург
от 25 000 ₽
Midlle PHP developer (backend)
ИТЦ Аусферр • Магнитогорск
от 100 000 до 160 000 ₽
Ещё вакансии
Заказы с Хабр Фриланса
Найти ошибку flutter_map
26 апр. 2024, в 05:31
1000 руб./за проект
Разработать электронику для весов с Wi-Fi
26 апр. 2024, в 01:22
1000 руб./в час
Очень срочно нужно помочь запустить программу с UI
26 апр. 2024, в 00:13
1000 руб./за проект
Ещё заказы