node.js - 使用消息选择器时使用 nodejs 订阅 ActiveMQ STOMP？

Question

我想使用 nodejs 订阅一个 activemq 服务器。我现在遇到的问题是，当我真的想使用“消息选择器”时，我的 node-stomp-client ( https://github.com/easternbloc/node-stomp-client) 当前正在获取所有从 MQ 发布的消息，这样我就不会获取所有发送到 nodejs 的消息。有没有一种方法可以像使用 Java 订阅 ActiveMQ 那样在 nodejs 中使用消息选择器？ (Java 中的消息选择器引用:http://timjansen.github.io/jarfiller/guide/jms/selectors.xhtml)

Answer 1

在 STOMP 中订阅 ActiveMQ 代理时，您可以使用选项名称“selector”在伴随订阅调用的选项值中包含 JMS 样式消息选择器。然后代理将应用选择器并过滤发送到您客户订阅的消息。

引用ActiveMQ STOMP documentation .

从 STOMP 客户端网站订阅将 header 作为参数。

var Stomp = require('stomp-client');
var destination = '/queue/someQueueName';
var client = new Stomp('127.0.0.1', 61613, 'user', 'pass');

client.connect(function(sessionId) {
    client.subscribe(destination, function(body, headers) {
        console.log('This is the body of a message on the subscribed queue:', body);
    });

    client.publish(destination, 'Oh herrow');
});