У меня есть приложение node.js, в котором я использую amqplib , который реализует AMQP 0.9.1
У меня есть несколько очередей, по которым принимаются данные.
В каждой из этих очередей есть функция-обработчик, которая обращается к сообщению в соответствующей очереди.
Я обновляюсь до AMQP 1.0 с использованием библиотеки rhea , которая имеет совершенно новые концепции для обработка сообщений. Я пытаюсь адресовать каждое сообщение с различным обработчиком для каждой очереди, но я не могу понять, как прослушивать определенную c очередь в соединении / сеансе.
Я могу только слушать на уровне контейнера, как здесь: https://github.com/amqp/rhea/blob/HEAD/examples/simple_recv.js
Нужно ли открывать новый контейнер в каждой очереди? Это единственный способ?
Заранее спасибо.