node.js - 如何检查stopmit node.js中的AMQ队列中是否没有消息可消费

Question

我正在使用node.js的stompit包连接到AMQ队列来订阅消息。我使用 ConnectFailover 类创建连接，使用 channelPool 类创建池。

我面临的问题是，一旦建立连接，如果队列中没有消息，那么它会保持连接。

如果没有消息可以从队列中读取，我需要一种断开连接的方法。我在 stompit documentation 中没有看到任何选项.

Answer 1

按照this issue，STOMP 无法做到这一点。一般来说，像 AMQ 这样的代理很少允许消费者检查消息计数等队列属性。

除非你能以某种方式leverage JMX从您的 node.js 代码中，最简单的方法是创建一个计时器，并使用 client.disconnect() 作为回调，并等待适合您系统的时间。每当消息被消耗时，重置计时器。