🚀 Big News: Socket Acquires Coana to Bring Reachability Analysis to Every Appsec Team.Learn more
Socket
DemoInstallSign in
Socket

amqplib-easy

Package Overview
Dependencies
Maintainers
33
Versions
28
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

amqplib-easy

Simplified API for interacting with AMQP

5.0.0
latest
Source
npm
Version published
Weekly downloads
45
-47.67%
Maintainers
33
Weekly downloads
 
Created
Source

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.

Keywords

amqp

FAQs

Package last updated on 25 Sep 2017

Did you know?

Socket

Socket for GitHub automatically highlights issues in each pull request and monitors the health of all your open source dependencies. Discover the contents of your packages and block harmful activity before you install or update your dependencies.

Install

Related posts