AMQP Connection manager
Wrapper for amqplib connection that reconnects on failure.
Installation
Usage
import {connect} from 'alpha-amqp-connection-wrapper';
connect('amqp://your.connection:1010/string?heartbeat=10')
.then((connection) => {
connection.channel;
connection.connection;
})
Events
-
retry
- on connection retry with number of retry attempt -
connection-error
- on internal connection error -
connected
- once connection established -
disconnected
- obvious -
channel
- once channel created -
error
- hard fail once we reach maximum amount of retry attempts
Configuration options
-
connection
- any value provided to ampq.connect -
useConfirmChannel
- Whether to use confirm channel - default false -
reconnect
-
failAfter
- maximum amount of reconnect attempts - default no limit -
backoffStrategy
- backoff strategy to use. Note that alpha-amqp-connection-manager exports "backoff" module so you don't need to have it defined in your local package.json in order to use it.
-
Debugging
The library uses great debugFn package. Call your app with DEBUG env variable set in order to see debugFn messages.
DEBUG=alpha-amqp-connection-manager:*
Full API
Available as Typescript definition files