antenna-amqp

0.1.3 • Public • Published

antenna-amqp

Build Coverage Quality Dependencies Tips

This module provides an AMQP 0-9-1 adapter for Antenna. AMQP 0-9-1 is implemented by popular messages brokers such as RabbitMQ.

Install

$ npm install antenna-amqp

Usage

Connect to Message Bus

var amqp = require('antenna-amqp');
var bus = new amqp.Bus();

bus.connect({ host: 'localhost', port: 5672 }, function() {
  console.log('connected!');
});

Dispatch Messages to Application

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!');
});

Publish Messages

bus.publish('events/on', { time: Date.now() }, function(err) {
  if (err) { throw err; }
  console.log('published message!');
});

Tests

$ npm install
$ make test

Credits

License

The MIT License

Copyright (c) 2014 Jared Hanson <http://jaredhanson.net/>

Readme

Keywords

Package Sidebar

Install

npm i antenna-amqp

Weekly Downloads

1

Version

0.1.3

License

none

Last publish

Collaborators

  • jaredhanson