我有一个 node.js 应用程序,我在其中使用实现 AMQP 0.9.1的amqplib
我有多个接收数据的队列。
这些队列中的每一个都有一个处理函数,用于处理其各自队列中的消息。
我正在使用具有全新消息处理概念的rhea库升级到 AMQP 1.0。我正在尝试使用每个队列的不同处理程序来处理每条消息,但我无法弄清楚如何在连接/会话中收听特定队列。
我只能像这里所做的那样在容器级别上收听:https ://github.com/amqp/rhea/blob/HEAD/examples/simple_recv.js
我需要在每个队列上打开一个新容器吗?这是唯一的方法吗?
提前致谢。