rmqp

Some sugar for amqp.node library

Features

• channel pool
• channel.publish and channel.sendToQueue replaced with a Writable stream
• channel.consume replaced with a Readable stream

Install

npm i rmqp

Usage

RabbitMQ Tutorials

Job queue

Publisher

const amqp = new AmqpClient(AMQP_URL);
amqp.assertQueue('job_queue');

const publisher = amqp.publisher(q, { contentType: 'application/json' });

publisher.write({taskId: 1, ...});
publisher.write({taskId: 2, ...});
publisher.end();

Worker

const amqp = new AmqpClient(AMQP_URL);
amqp.assertQueue('task_queue');

amqp.subscriber(q, { noAck: false, prefetch: 1 })
    .on('data', (message) => {
        ...
        message.ack();
    });

API

Documentation