我想使用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消息選擇器
- 2. 使用ActiveMQ取消訂閱持久訂閱者
- 3. 如何在Stomp/JSON中使用ActiveMQ中的JMS消息轉換
- 4. Spring STOMP訂閱的最佳實踐 - 訂閱消息確認
- 5. ActiveMQ/Stomp當一條消息禁用消費者時調試
- 6. STOMP選擇器Python對於ActiveMq
- 7. 如何使用JMSTemplate和選擇器從ActiveMQ接收消息?
- 8. ActiveMQ:使用Django Auth with Stomp
- 9. Spring websocket stomp sock js activemq耐用的訂閱
- 10. 使用Mosquitto返回消息訂閱?
- 11. 當通過STOMP發送時,ActiveMQ將消息存儲在Base64中?
- 12. 如何使用STOMP配置ActiveMQ?
- 13. 使用Websocket連接stomp和ActiveMQ
- 14. 如何在使用Stomp協議的ActiveMQ/JMS選擇器中使用算術條件和操作符
- 15. 當我使用NServiceBus訂閱消息時會發生什麼?
- 16. 如何使用ActiveMQ Blob消息?
- 17. 持久訂閱ActiveMQ
- 18. 如何使用API在Google閱讀器中訂閱訂閱源
- 19. 如何在訂閱時使mosquitto_sub打印主題和消息#
- 20. Activemq stomp碼頭
- 21. JSON,Stomp和ActiveMQ
- 22. ActiveMQ,WebSocket和Stomp
- 23. 如何在NodeJS包中爲XMPP構建訂閱消息?
- 24. 使用nodejs作爲服務器使用Python發送socket.io消息
- 25. 使用redux-saga處理訂閱/取消訂閱大量事件
- 26. AZURE服務總線如何使用訂閱消息來處理消息?
- 27. 使用react-native-stripe-api取消訂閱
- 28. 從Java應用程序訂閱/發佈消息到/從SocketIO/nodejs服務器發佈消息?
- 29. 我可以在OpenMQ UMS中使用消息選擇器嗎?
- 30. 使用發佈/訂閱模型發送批量消息
很確定你可以用'patrun'工作,如果你正確地格式化了你的消息。 – Gntem