qpid

A native wrapper around Apache Qpid, specifically the AMQP 1.0 Proton C API

node-qpid

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:

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!