Найс, тесты не работают потому что для AMQP (RabbitMQ) нет блокирующего Queue.get(), сервер отвечает сразу же
И либа это никак не изменяет, предлагая ставить префетч в 1 сообщение и прекращать consume
Штош, выбора у меня немного
Найс, тесты не работают потому что для AMQP (RabbitMQ) нет блокирующего Queue.get(), сервер отвечает сразу же Штош, выбора у меня немного 2 comments
|
@mo обычно такие вещи макают. А для функциональных тестов обычно есть переключение на тип очереди in_memory