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