0.3.1 • Published 2 years ago
alpha-amqp-connection-manager v0.3.1
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 attemptconnection-error
- on internal connection errorconnected
- once connection establisheddisconnected
- obviouschannel
- once channel createderror
- hard fail once we reach maximum amount of retry attempts
Configuration options
connection
- any value provided to ampq.connectuseConfirmChannel
- Whether to use confirm channel - default falsereconnect
-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