Ответ

virusav 09.09 09:18

Надо понимать, что если сообщений нет, amqp ждет их до timeout (по умолчанию 30 минут). Будет исключение (в отличии от варианта с callback, который завершается без ошибки).

Идея была в том, чтобы получать N сообщений через прослушку и заканчивать ее, а не висеть до упора, т.к. через функцию получения одного сообщения было бы дольше за счет коннекта на каждое сообщение.

Еще было бы удобно передавать N=0 или -1, чтобы прослушка с callback заканчивалась, как только заканчиваются сообщения, чтобы вручную не отслеживать конец очереди.

Итого по прослушке:
1. Передали N=10 без callback - получили 10 сообщений (или меньше, если в очереди столько нет) и вышли.
2. Передали N=0 или -1 с callback - когда заканчиваются сообщения, выходим.

---