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:
// Sending
var Messenger = require('qpid').proton.Messenger;
var m = new Messenger();
m.send({address: address, body: message}, function(err) {
if (err) {
console.log("Error sending message: " + err.message);
}
});// Receiving
var Messenger = require('qpid').proton.Messenger;
var m = new Messenger();
m.on('subscribed', function(url) {
console.log("Subscribed to " + url);
});
m.on('message', function(message) {
console.log(message.body);
});
m.subscribe(address).receive();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
It expects you to already have version 0.3 of the qpid-proton library installed on your (Linux) system.
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!