hapi-amqp
This library is a hapi plugin for amqplib.
API
connection
- The amqplib connection objectcreateChannel(connection, cb)
createConfirmChannel(connection, cb)
Both of the channel objects call the callback (cb
) with err, channel
as arguments.
The connection is established once and is reused between requests.
It passes the options provided directly to amqplib
, with the
exception of the api
argument which can be 'promise'
which will
use the promise based API for amqplib instead of the callback one.
Example
amqp;