jrs

JRS (Jack Rabbit Micro Serivce)

This module wraps the Jack Rabbit module to make it easy to integrate RabbitMQ into micro-services via event emitter pattern.

Usage

 
var jrs = require('jrs');
 
var svc = jrs({ server: 'amqp://localhost', queue: 'foo.bar'});
 
svc.on('job', function(job, ack) {
  // process job and acknowledge  
  console.log(job);
  ack();
});
 
svc.on('error', function(err) {
  // handle error
});
 

or with highland

var jrs = require('jrs');
var _ = require('highland');
 
var handleJob = /* ... */;
var handleError = /* ... */;
 
var svc = jrs({ server: 'amqp://localhost', queue: 'foo.bar'});
 
_('job', svc, ['job', 'ack']).each(handleJob);
_('error', svc).each(handleError);
 

Install

npm install jrs --save

LICENSE

MIT

Contributing

(see CONTRIBUTING.md)

Thanks

• Creator of JackRabbit
• Creator of Node
• Creator of OPEN Open Source

Contributors