A lightweight and simple Node.js library for interacting with RabbitMQ. This library provides an easy-to-use interface to send and consume messages to and from RabbitMQ queues.
npm i lup-id-amqp
To use the RabbitMQ Client library, first import the RabbitMqClient class:
import { RabbitMqClient } from 'lup-id-amqp';
Then, create an instance of the RabbitMqClient class with the following options:
const rabbitmqClient = new RabbitMqClient({
hostname: 'localhost'
});
To consume messages from a queue, use the consume method:
rabbitmqClient.consume('queue-name', (message) => {
console.log(message);
});
To create a new queue, use the addQueue method:
rabbitmqClient.addQueue('queue-name');
To send a message to a queue, use the send method:
rabbitmqClient.sendToQueue('queue-name', 'message');
To close the connection and channel to RabbitMQ, use the close method:
rabbitmqClient.close();
This library is licensed under the MIT License. See the LICENSE file for more information.