alpha-amqp-connection-manager
v0.3.1
Published
Connection manager for AMQP
Downloads
9
Maintainers
Readme
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 limitbackoffStrategy
- 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