RabbitMQueue

Simple queueing package for task queueing using rabbitmq

Prerequisite

Install and start rabbitmq. Here's the link to download and installation guide.

Installation

npm i rabbitmqueue

Queue Daemon

Create a js file on the root directory of your project. Let's call it rmq.js.

const rabbitmqueue = require('rabbitmqueue');

const consumers = {
    'default': function (data) {
        console.dir(data);
    }
};

rabbitmqueue.init("amqp://localhost", consumers);

Here consumers is an object containing queue names as key and job handling function as value.

We initialize the daemon using init where you must pass rabbitmq connection string and consumer object.

Start Daemon

node rmq.js

We can use PM2 on production.

Producer in action

Here's how to push messages to queue.

const rabbitmqueue = require('rabbitmqueue');

const producer = rabbitmqueue.producer("amqp://localhost", ['default']);

producer.produce('default', {
    'key1': 'value1',
    'key2': 'value2'
});