rabbitmq — цикл php-amqplib, пока есть только сообщения

Question

rabbitmq — цикл php-amqplib, пока есть только сообщения

Он зацикливается, пока на канале зарегистрированы обратные вызовы

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

Дело в том, что мне нужно получить не более 100 сообщений из очереди, например. Например, если есть только 80, он должен вернуть только 80 и выйти из цикла.

Спасибо

0

php php-amqplib rabbitmq

Решение

Другие решения

Других решений пока нет …

Источник

Accepted Answer

Будет ли следующий код работать для вас?

$callbacks = count($ch->callbacks);

for ($i = 0, $count = $callbacks < 100 ? $callbacks : 100; $i < $count; $i++) {
$ch->wait();
}

0