Interface AmqpConnectionManager

Readonly channelCount

Readonly connection

Optional connectionOptions

heartbeatIntervalInSeconds

reconnectTimeInSeconds

addListener

• addListener(event, listener): AmqpConnectionManager

• Parameters

  • event: string

  • listener: ((...args) => void)

    • • (...args): void

      • Parameters

        • Rest ...args: any[]

          Rest

        Returns void

  Returns AmqpConnectionManager

• addListener(event, listener): AmqpConnectionManager

• Parameters

  • event: "connect"

  • listener: ConnectListener

  Returns AmqpConnectionManager

• addListener(event, listener): AmqpConnectionManager

• Parameters

  • event: "connectFailed"

  • listener: ConnectFailedListener

  Returns AmqpConnectionManager

• addListener(event, listener): AmqpConnectionManager

• Parameters

  • event: "blocked"

  • listener: ((arg) => void)

    • • (arg): void

      • Parameters

        • arg: {
              reason: string;
          }

          • reason: string

        Returns void

  Returns AmqpConnectionManager

• addListener(event, listener): AmqpConnectionManager

• Parameters

  • event: "unblocked"

  • listener: (() => void)

    • • (): void

      • Returns void

  Returns AmqpConnectionManager

• addListener(event, listener): AmqpConnectionManager

• Parameters

  • event: "disconnect"

  • listener: ((arg) => void)

    • • (arg): void

      • Parameters

        • arg: {
              err: Error;
          }

          • err: Error

        Returns void

  Returns AmqpConnectionManager

close

• close(): Promise<void>

• Returns Promise<void>

connect

• connect(options?): Promise<void>

• Parameters

  • Optional options: {
        timeout?: number;
    }

    Optional

    • Optional timeout?: number

  Returns Promise<void>

createChannel

• createChannel(options?): default

• Parameters

  • Optional options: CreateChannelOpts

    Optional

  Returns default

isConnected

• isConnected(): boolean

• Returns boolean

listeners

• listeners(eventName): Function[]

• Parameters

  • eventName: string | symbol

  Returns Function[]

on

• on(event, listener): AmqpConnectionManager

• Parameters

  • event: string

  • listener: ((...args) => void)

    • • (...args): void

      • Parameters

        • Rest ...args: any[]

          Rest

        Returns void

  Returns AmqpConnectionManager

• on(event, listener): AmqpConnectionManager

• Parameters

  • event: "connect"

  • listener: ConnectListener

  Returns AmqpConnectionManager

• on(event, listener): AmqpConnectionManager

• Parameters

  • event: "connectFailed"

  • listener: ConnectFailedListener

  Returns AmqpConnectionManager

• on(event, listener): AmqpConnectionManager

• Parameters

  • event: "blocked"

  • listener: ((arg) => void)

    • • (arg): void

      • Parameters

        • arg: {
              reason: string;
          }

          • reason: string

        Returns void

  Returns AmqpConnectionManager

• on(event, listener): AmqpConnectionManager

• Parameters

  • event: "unblocked"

  • listener: (() => void)

    • • (): void

      • Returns void

  Returns AmqpConnectionManager

• on(event, listener): AmqpConnectionManager

• Parameters

  • event: "disconnect"

  • listener: ((arg) => void)

    • • (arg): void

      • Parameters

        • arg: {
              err: Error;
          }

          • err: Error

        Returns void

  Returns AmqpConnectionManager

once

• once(event, listener): AmqpConnectionManager

• Parameters

  • event: string

  • listener: ((...args) => void)

    • • (...args): void

      • Parameters

        • Rest ...args: any[]

          Rest

        Returns void

  Returns AmqpConnectionManager

• once(event, listener): AmqpConnectionManager

• Parameters

  • event: "connect"

  • listener: ConnectListener

  Returns AmqpConnectionManager

• once(event, listener): AmqpConnectionManager

• Parameters

  • event: "connectFailed"

  • listener: ConnectFailedListener

  Returns AmqpConnectionManager

• once(event, listener): AmqpConnectionManager

• Parameters

  • event: "blocked"

  • listener: ((arg) => void)

    • • (arg): void

      • Parameters

        • arg: {
              reason: string;
          }

          • reason: string

        Returns void

  Returns AmqpConnectionManager

• once(event, listener): AmqpConnectionManager

• Parameters

  • event: "unblocked"

  • listener: (() => void)

    • • (): void

      • Returns void

  Returns AmqpConnectionManager

• once(event, listener): AmqpConnectionManager

• Parameters

  • event: "disconnect"

  • listener: ((arg) => void)

    • • (arg): void

      • Parameters

        • arg: {
              err: Error;
          }

          • err: Error

        Returns void

  Returns AmqpConnectionManager

prependListener

• prependListener(event, listener): AmqpConnectionManager

• Parameters

  • event: string

  • listener: ((...args) => void)

    • • (...args): void

      • Parameters

        • Rest ...args: any[]

          Rest

        Returns void

  Returns AmqpConnectionManager

• prependListener(event, listener): AmqpConnectionManager

• Parameters

  • event: "connect"

  • listener: ConnectListener

  Returns AmqpConnectionManager

• prependListener(event, listener): AmqpConnectionManager

• Parameters

  • event: "connectFailed"

  • listener: ConnectFailedListener

  Returns AmqpConnectionManager

• prependListener(event, listener): AmqpConnectionManager

• Parameters

  • event: "blocked"

  • listener: ((arg) => void)

    • • (arg): void

      • Parameters

        • arg: {
              reason: string;
          }

          • reason: string

        Returns void

  Returns AmqpConnectionManager

• prependListener(event, listener): AmqpConnectionManager

• Parameters

  • event: "unblocked"

  • listener: (() => void)

    • • (): void

      • Returns void

  Returns AmqpConnectionManager

• prependListener(event, listener): AmqpConnectionManager

• Parameters

  • event: "disconnect"

  • listener: ((arg) => void)

    • • (arg): void

      • Parameters

        • arg: {
              err: Error;
          }

          • err: Error

        Returns void

  Returns AmqpConnectionManager

prependOnceListener

• prependOnceListener(event, listener): AmqpConnectionManager

• Parameters

  • event: string

  • listener: ((...args) => void)

    • • (...args): void

      • Parameters

        • Rest ...args: any[]

          Rest

        Returns void

  Returns AmqpConnectionManager

• prependOnceListener(event, listener): AmqpConnectionManager

• Parameters

  • event: "connect"

  • listener: ConnectListener

  Returns AmqpConnectionManager

• prependOnceListener(event, listener): AmqpConnectionManager

• Parameters

  • event: "connectFailed"

  • listener: ConnectFailedListener

  Returns AmqpConnectionManager

• prependOnceListener(event, listener): AmqpConnectionManager

• Parameters

  • event: "blocked"

  • listener: ((arg) => void)

    • • (arg): void

      • Parameters

        • arg: {
              reason: string;
          }

          • reason: string

        Returns void

  Returns AmqpConnectionManager

• prependOnceListener(event, listener): AmqpConnectionManager

• Parameters

  • event: "unblocked"

  • listener: (() => void)

    • • (): void

      • Returns void

  Returns AmqpConnectionManager

• prependOnceListener(event, listener): AmqpConnectionManager

• Parameters

  • event: "disconnect"

  • listener: ((arg) => void)

    • • (arg): void

      • Parameters

        • arg: {
              err: Error;
          }

          • err: Error

        Returns void

  Returns AmqpConnectionManager

reconnect

• reconnect(): void

• Returns void

removeListener

• removeListener(event, listener): AmqpConnectionManager

• Parameters

  • event: string

  • listener: ((...args) => void)

    • • (...args): void

      • Parameters

        • Rest ...args: any[]

          Rest

        Returns void

  Returns AmqpConnectionManager