2

Смотрю насколько мне под задачу подходит RabbitMQ.

Код из примера

    $consumerTag = gethostname() . '_' . getmypid();
    $connection = $this->getConnection();
    $channel = $this->getChannel();
    $channel->basic_qos(null, 1, null);
    $channel->queue_bind(self::QUEUE_NAME, 'exchange');
    $channel->basic_consume(self::QUEUE_NAME, $consumerTag, false, true, false, false, function($msg) {
        echo $msg->body, "\n";
        sleep(2);
    });

    while(count($channel->callbacks)) {
        echo time()."\r\n";
        $channel->wait();
    }

Возможно в callback'e получить несколько сообщений из очереди? Возможно это вообще противоречит идеологии RabbitMQ?

2
  • callback наверняка вызывается для каждой мессаги отдельно. но это же не может быть преградой для героя
    – Sergey
    12 апр 2016 в 15:02
  • @Sergey, все так =)
    – flax
    12 апр 2016 в 15:14

1 ответ 1

1

Разобрался, для получения следующего сообщения без ожидания можно воспользоваться

$channel->basic_get(self::QUEUE_NAME)

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.