Amqplib rabbitmq library object oriented enhancement.
npm install amqplib-plusAmqplib-plus amplifies the original npm amqplib library with OOP approach.
Amqplib-plus adds following features:
- connection auto-reconnect
- easy to use object oriented publisher
- easy to use object oriented consumer that runs user defined callback for every consumed message
$ npm install amqplib-plus``typescript
import {Connection, Consumer, Publisher} from "amqplib-plus";
import {Channel, Message} from "amqplib";
import {CustomConsumer} from "./CustomConsumer"; // CustomConsumer is your own consumer implementation that extends amqplib-plus Consumer
const queue = { name: "some_queue_name", options: {} };
const msgContent = "some content";
// callback to be called when creating the consumer, before it starts consuming
// consumer wants to be sure the queue exists
const consumerPrepare: any = (ch: Channel) => {
return ch.assertQueue(queue.name, queue.options);
};
// the callback to be called on every consumed message
// you process the message as you like and tken ack/reject it as you wish
const handleMsg = (msg: Message, ch: Channel) => {
console.log(msg.content.toString());
ch.ack(msg);
};
// creates the connection to rabbitmq broker
const amqpConn = new Connection(
{ connectionString: 'amqp://guest:guest@localhost:5672/' },
console // you may use custom logger or avoid it to disable logging
);
// create the consumer using existing connection and start the consumption
const consumer = new CustomConsumer(conn, consumerPrepare, handleMsg);
consumer.consume(queue.name, {});
// callback to be called when creating the publisher before it starts publishing
// publisher wants to be sure the publishing queue exists
const publisherPrepare: any = (ch: Channel) => {
return ch.assertQueue(queue.name, queue.options);
};
// create the publisher using the existing connection
const publisher = new Publisher(conn, publisherPrepare);
// send a message that consumer should consume
publisher.sendToQueue(queue.name, Buffer.from(msgContent), {});
`
Create pull request to https://github.com/hanaboso/amqplib-plus repository.
Please note that this lib is written in typescript. Your contribution is very welcome.
.Or you can use custom rabbitmq instance in test by running
RABBIT_DSN=amqp://guest:guest@yourserver:5672/ npm run testAlternatively you can run: