Interface AmqpConnectionManagerOptions

Hierarchy

  • AmqpConnectionManagerOptions

Properties

connectionOptions? findServers? heartbeatIntervalInSeconds? reconnectTimeInSeconds?

Properties

Optional connectionOptions

connectionOptions?: AmqpConnectionOptions

Connection options, passed as options to the amqplib.connect() method.

Optional findServers

findServers?: ((callback) => void) | (() => Promise<ConnectionUrl | ConnectionUrl[]>)

findServers is a function that which returns one or more servers to connect to. This should return either a single URL or an array of URLs. This is handy when you're using a service discovery mechanism such as Consul or etcd. Instead of taking a callback, this can also return a Promise. Note that if this is supplied, then urls is ignored.

Type declaration

    • (callback): void

    • Parameters

      Returns void

Type declaration

Optional heartbeatIntervalInSeconds

heartbeatIntervalInSeconds?: number

Interval to send heartbeats to broker. Defaults to 5 seconds.

Optional reconnectTimeInSeconds

reconnectTimeInSeconds?: number

The time to wait before trying to reconnect. If not specified, defaults to heartbeatIntervalInSeconds.

Settings

Member Visibility

Theme

On This Page

Generated using TypeDoc