node.js - 如何使用 ActiveMQ 仪表板查看消费者的优先级？

Question

从 ActiveMQ 文档（https://activemq.apache.org/consumer-priority）来看，似乎代理确实支持消费者优先级。我正在尝试使用 nodejs 和 rhea 库来使用此功能。问题是，没有明确的文档如何做到这一点——我什至找不到一个地方来查看我是否设法改变了消费者的优先级。仪表板 (localhost:8161) 确实显示了消息的优先级，但如果消费者..

标签： node.jsactivemqamqprhea

Answer 1

AMQP 接收器可以通过添加与 Openwire 客户端添加到 JMS 目标相同的选项来设置代理创建的内部创建的消费者的优先级。在这种情况下，可以通过在创建接收器链接时将选项以及所需的目标名称添加到源提供的地址来完成。

source.setAddress("queue://destination?consumer.priorty=64")

我对 Rhea 不熟悉，所以我不确定管理它的确切代码，但总体思路应该很清楚。

感兴趣的观察者可以调试代理代码的这个区域以查看正在应用的目标选项。