Sign Up for Free

RunKit +

Try any Node.js package right in your browser

This is a playground to test code. It runs a full Node.js environment and already has all of npm’s 400,000 packages pre-installed, including amqplib-plus with all npm packages installed. Try it out:

var amqplibPlus = require("amqplib-plus")

This service is provided by RunKit and is not affiliated with npm, Inc or the package authors.

amqplib-plus v1.0.3

Amqplib rabbitmq library objet oriented enhancement.

Amqplib-plus

Amqplib-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

How to install:

$ npm install amqplib-plus

How to use

Basic example - publish and consume

import {Connection, Consumer, Publisher} from "amqplib-plus";
import {Channel, Message} from "amqplib";

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 Consumer(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), {});

More examples and tutorials

Connection

Publisher

Consumer

How to contribute:

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.

How to run the tests

If you have running rabbitmq instance, set env variable values defined used in test/config.ts (default rabbitmq dsn is 'amqp://guest:guest@localhost:5672/') and run: npm run test.

Or you can use custom rabbitmq instance in test by running RABBIT_DSN=amqp://guest:guest@yourserver:5672/ npm run test

Alternatively you can run: make test which will start rabbitmq instance for you and run tests in docker-compose.

Metadata

RunKit is a free, in-browser JavaScript dev environment for prototyping Node.js code, with every npm package installed. Sign up to share your code.
Sign Up for Free