amqplib-easy

5.0.0 • Public • Published

amqplib-easy

Build Status

amqplib but easy! Let us manage your channels, connections, assertions and bindings for you, so you can just send messages.

Installation

npm install --save amqplib-easy

Usage

var amqp = require('amqplib-easy')('amqp://foo:bar@amqp.lol');
 
amqp.consume(
  {
    exchange: 'cat',
    queue: 'found_cats',
    topics: [ 'found.*' ]
  },
  function (cat) {
    console.log('Found a cat named', cat.json.name);
  }
);
 
amqp.publish({ exchange: 'cat' }, 'found.tawny', { name: 'Sally' });
 
amqp.sendToQueue({ queue: 'found_cats' }, { name: 'Fred' });

yields

Found a cat named Sally
Found a cat named Fred

API

Logging

All methods return a promise, so you can attach logging to them via the following.

amqp.sendToQueue({ queue: 'found_cats' }, { name: 'Fred' })
  .then(function () { console.log('sent to queue'); })
  .catch(function (err) { console.error('sending failed', err); });

Connection Cleanup

diehard is used for cleaning up connections before the process exits. To ensure connections are cleaned up,

npm install --save diehard

and in your application's entry point, add

require('diehard').listen();

You can also explicitly close all connections by calling require('amqplib-easy').close(). You may pass a callback to this function which will be invoked once all connections have been closed.

Readme

Keywords

Package Sidebar

Install

npm i amqplib-easy

Weekly Downloads

147

Version

5.0.0

License

MIT

Last publish

Collaborators

  • jasif-wm
  • shyam.mohan
  • qbibrahim
  • sidharth.n
  • hariqb
  • arjuncprasannan
  • renjith_ram_qburst
  • anasqburst
  • jyothis-qb
  • qburst-pratyush
  • cdrohithmqb
  • sudheeshqburst
  • davoodul
  • mable-liza-mathew
  • sowmyab
  • anoop-kuttikkattu
  • munisa
  • dheerajds
  • arjunqb
  • ashishqburst
  • lanetix-system
  • manu-kodiyan-winmore
  • dnm-winmore
  • mkdyanugk
  • vigneshk7
  • soumyaarun
  • aswanth
  • sajith.qb
  • dhiluraj-qburst
  • anandqb
  • arun-dtk
  • vikasqb
  • acpradosh1234