у меня не блокируется
channel.basicConsume("blocks", true, deliverCallback, { consumerTag -> })
не нашел инфы в доках как сделать его блокирующимся
на сайте rmq все примеры заканчиваются на такой строчке
Он и не должен блокироваться, дока говорит, что basicConsume подписывает асинхронно
Обсуждают сегодня