A native wrapper around Apache Qpid, specifically the AMQP 1.0 Proton C API
A Node.js native wrapper around Apache Qpid, specifically the AMQP 1.0 Proton C API
You can use it to exchange messages with AMQP 1.0 brokers:
// Sendingvar Messenger = require'qpid'protonMessenger;var m = ;msendaddress: address body: messageif errconsole.log"Error sending message: " + errmessage;;
// Receivingvar Messenger = require'qpid'protonMessenger;var m = ;mon'subscribed'console.log"Subscribed to " + url;;mon'message'console.logmessagebody;;msubscribeaddressreceive;
The module has been preliminarily tested against:
- Windows Azure Service Bus
- ActiveMQ 5.8 snapshot builds w/ AMQP 1.0 support
- RabbitMQ with the AMQP 1.0 Plugin
Peer-to-peer support is a work in progress
It expects you to already have version 0.3 of the qpid-proton library installed on your (Linux) system. Windows support will follow when version 0.4 of proton is released.
It's still rough around the edges and not ready for prime time, but pull requests are welcomed!
node_sqlite3 has been an invaluable resource while writing this native module!