1

我有一个 node.js 应用程序,我在其中使用实现 AMQP 0.9.1的amqplib

我有多个接收数据的队列。

这些队列中的每一个都有一个处理函数,用于处理其各自队列中的消息。

我正在使用具有全新消息处理概念的rhea库升级到 AMQP 1.0。我正在尝试使用每个队列的不同处理程序来处理每条消息,但我无法弄清楚如何在连接/会话中收听特定队列。

我只能像这里所做的那样在容器级别上收听:https ://github.com/amqp/rhea/blob/HEAD/examples/simple_recv.js

我需要在每个队列上打开一个新容器吗?这是唯一的方法吗?

提前致谢。

4

0 回答 0