amqp-consumer

npm install amqp-consumer

amqp-consumer is a module to help expedite the process with hooking into a messaging channel. By simply providing options and event handlers, you can get to writing the logic of your consumer quicker than ever.

Options

Option	Description	Default
name (string)	Name to identify consumer in output logs.	Consumer
queue (string)	Amqp channel that consumer will listen on.	test
host (string)	URL of amqp host to connect to.	amqp://localhost:5672
raw (boolean)	Whether to pass the raw amqp buffer to consume event	false (returns as string)
quiet (boolean)	Suppress output logs.	false

How to Use

'use strict';

var Consumer = require('amqp-consumer');

var opts = {
    name: 'Adam Consumer',
    queue: 'testing',
    host: 'amqp://localhost:5672',
    raw: false,
    quiet: false
};

var consumer = new Consumer(opts);

consumer.on('consume', (msg) => {

    console.log(`Received ${msg}`);
    // Handle message and perform logic

});

consumer.on('error', (err) => {

    console.log('Error!');
    console.log(err);

});

consumer.on('connect', () => {

    console.log('Connected to amqp!');

});

consumer.on('disconnect', (reason) => {

    console.log('Disconnected!');
    console.log(reason);

});

consumer.connect();