@jackrabbit/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
// ready to start actually scripting
})
})Additionally, using this module abstracts the dependency on amqplib (a little).
Install
npm install @jackrabbit/channel
Usage
The exported function takes the same parameters as amqplib.connect,
and yields channel and connection objects.
const RabbitChannel = require('@jackrabbit/channel')
RabbitChannel(url, options, (err, channel, connection) {
if (err) throw err
// script away
})Contributing
Contributions welcome! Please read the contributing guidelines first.