我正在开发一个 Socket.IO 应用程序,它使用来自 ActiveMQ 队列的消息。我正在使用 Node.js 的 STOMP 库。
我可以从队列中发送和接收消息,但我想获取队列中已存在的待处理消息的列表。有没有办法使用 STOMP 来实现这一目标?如果没有,任何人都可以将我指向另一个可以为我提供待处理消息详细信息的库。
const Stomp = require("stomp-client");
const client = new Stomp("localhost", 61613);
client.connect((sessionId) => {
console.log(`🚀 receiver connected successfully.`);
client.subscribe("/queue/PENDING", onMessageCallback);
});
const onMessageCallback = (body, headers) => {
console.log(`🚀 ~ onMessageCallback ~ body:`, body);
console.log(`🚀 ~ onMessageCallback ~ headers:`, headers);
};
查看 ActiveMQ 消息 REST API。
仅供参考——STOMP 协议支持浏览,并且存在 ActiveMQ 服务器端浏览实现,但我的快速扫描没有看到专门针对它的单元测试。您可以启动代理并添加浏览器选项来订阅,看看它是否“正常工作”。