2017-04-17 100 views
0

我有一個JAVA api需要使用來自ActiveMQ的數據。配置ActiveMQ:如何使用Node.js發送消息到Apache ActiveMQ隊列

客戶端向我提供了主機,端口和API密鑰的詳細信息。

林在這個ActiveMQ的一個紐比和需要有關如何自隊列工作在TCP協議建立初始隊列連接的建議。

我建議用目前我指用各種語言

通過ActiveMQ的支持的客戶端庫之一:如何配置或執行(如果我使用「如何發送http://activemq.apache.org/cross-language-clients.html

極品建議下面的代碼中,從上面的鏈接中發送到帶有Node.js的Apache ActiveMQ隊列的消息)。

const stompit = require('stompit'); 

stompit.connect({ host: 'localhost', port: 61613 }, (err, client) => { 
const frame = client.send({ destination: 'SampleQueue' }); 

frame.write('Simples Assim'); 

frame.end(); 

client.disconnect(); 
}); 

假設我的機器中沒有任何Node環境設置。

回答

0

如果向您公開的端點正在爲代理使用標準的基於TCP的端點,那麼您需要使用客戶端,該客戶端使用作爲ActiveMQ JMS客戶端的本機協議的OpenWire協議通過TCP層進行連接, C++ ActiveMQ-CPP客戶端以及NMS.ActiveMQ .NET客戶端。您不能使用STOMP客戶端或其他協議客戶端直接與OpenWire TCP傳輸連接器進行通話。

0

您可以使用STOMP協議偵聽或發送消息給ActiveMQ。只需使用https://github.com/gdaws/node-stomp 中的示例(並且您肯定需要在將運行該腳本的計算機上安裝Nodejs)。

我不確定您的工作流程是如何與Java API相關的,但如果該API向ActiveMQ發送一些消息並且您需要處理該消息,則可以使用stompit。您只需訂閱存儲郵件的隊列即可。如果你需要發送回覆信息,你也可以對你想要的任何隊列進行發送。

相關問題