jrs

A wrapper library to handle jackrabbit jobs via emit emitter pattern.

Usage no npm install needed!

<script type="module">
  import jrs from 'https://cdn.skypack.dev/jrs';
</script>

README

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