This module provides an AMQP 0-9-1 adapter for Antenna. AMQP 0-9-1 is implemented by popular messages brokers such as RabbitMQ.
$ npm install antenna-amqp
var amqp = require('antenna-amqp');
var bus = new amqp.Bus();
bus.connect({ host: 'localhost', port: 5672 }, function() {
console.log('connected!');
});
var antenna = require('antenna');
var app = antenna();
bus.on('message', app);
bus.subscribe('events/on', function(err) {
if (err) { throw err; }
console.log('subscribed to topic!');
});
bus.publish('events/on', { time: Date.now() }, function(err) {
if (err) { throw err; }
console.log('published message!');
});
$ npm install
$ make test
Copyright (c) 2014 Jared Hanson <http://jaredhanson.net/>