@modulus/rabbit-channel
wrapper for creating a rabbitMQ connection and opening a channel
It gets tedious to start every rabbit interaction with the same two function
calls:
const Amqp = require('amqplib/callback_api')
Amqp.connect(url, options, (err, connection) => {
if (err) throw err
connection.createChannel((err, channel) => {
if (err) throw err
})
})
Additionally, using this module abstracts the dependency on amqplib
(a little).
Install
npm install @modulus/rabbit-channel
Usage
The exported function takes the same parameters as amqplib.connect
,
and yields channel
and connection
objects.
const RabbitChannel = require('@modulus/rabbit-channel')
RabbitChannel(url, options, (err, channel, connection) {
if (err) throw err
})
Contributing
Contributions welcome! Please read the contributing guidelines first.
License
MIT