我想使用nodejs订阅activemq服务器。我现在面临的问题是,我现在的node-stomp-client(https://github.com/easternbloc/node-stomp-client)正在获取所有正在发布的消息,当我真的想使用“消息选择器”,以便我不会获得所有消息消息传到nodejs。有没有一种方法可以在nodej中使用消息选择器,就像使用Java订阅ActiveMQ一样? (Java中的消息选择器引用:http://timjansen.github.io/jarfiller/guide/jms/selectors.xhtml)使用nodejs在使用消息选择器时订阅ActiveMQ STOMP?
3
A
回答
1
在订阅ActiveMQ代理的STOMP中,可以使用选项名称“selector”在伴随订阅调用的选项值中包含JMS样式的消息选择器。代理将应用选择器并过滤发送到客户订阅的消息。
请参阅ActiveMQ STOMP documentation。
从STOMP客户端网站订阅需要标头作为参数。
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');
});
相关问题
- 1. ActiveMQ - 使用选择器订阅的STOMP失败
- 2. ActiveMQ消息选择器
- 3. ActiveMQ with Ruby Stomp gem - 订阅失败
- 4. 使用ActiveMQ取消订阅持久订阅者
- 5. 如何在Stomp/JSON中使用ActiveMQ中的JMS消息转换
- 6. 是否可以使用ActiveMQ发布/订阅消息传递
- 7. Spring STOMP订阅的最佳实践 - 订阅消息确认
- 8. ActiveMQ/Stomp当一条消息禁用消费者时调试
- 9. STOMP选择器Python对于ActiveMq
- 10. 使用ruby和stomp将消息写入ActiveMQ
- 11. 使用python从ActiveMQ队列接收单条消息STOMP
- 12. 如何使用JMSTemplate和选择器从ActiveMQ接收消息?
- 13. ActiveMQ:使用Django Auth with Stomp
- 14. Spring websocket stomp sock js activemq耐用的订阅
- 15. 当没有订阅者时在ActiveMQ上过期消息
- 16. 使用Mosquitto返回消息订阅?
- 17. 如何阅读JMS消息而不消耗它们 - 使用ActiveMQ
- 18. 当通过STOMP发送时,ActiveMQ将消息存储在Base64中?
- 19. 使用服务或侦听器在ActiveMQ中使用消息
- 20. Aysnc ActiveMQ消息使用者无法使用消息
- 21. 如何使用STOMP配置ActiveMQ?
- 22. 使用Websocket连接stomp和ActiveMQ
- 23. 使用Go-Stomp为ActiveMQ缓存连接
- 24. 当我使用NServiceBus订阅消息时会发生什么?
- 25. activemq,jms主题和订阅者与选择器
- 26. 如何在使用Stomp协议的ActiveMQ/JMS选择器中使用算术条件和操作符
- 27. 使用PAHO订阅和阅读MQTT消息
- 28. 订阅log4net消息
- 29. Stomp消费者使用deferred.inlinecallback
- 30. Java,activemq,在订阅期间更改消息侦听器的设置
很确定你可以用'patrun'工作,如果你正确地格式化了你的消息。 – Gntem