我想使用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