AMQP 0-9-1 client over TCP socket.

Hierarchy

  • AMQPBaseClient
    • AMQPClient

Constructors

Properties

blocked?: string
bufferPool: AMQPView[] = []
channelMax: number = 0
channels: AMQPChannel[]
closePromise?: [((value?) => void), ((err) => void)]

Type declaration

    • (value?): void
    • Parameters

      • Optional value: void

      Returns void

Type declaration

    • (err): void
    • Parameters

      • err: Error

      Returns void

closed: boolean = true
connectPromise?: [((conn) => void), ((err) => void)]

Type declaration

    • (conn): void
    • Parameters

      • conn: AMQPBaseClient

      Returns void

Type declaration

    • (err): void
    • Parameters

      • err: Error

      Returns void

frameBuffer: Buffer
frameMax: number
framePos: number
frameSize: number
heartbeat: number
host: string
insecure: boolean
logger: undefined | null | Logger = console
name?: string
onUpdateSecretOk?: ((value?) => void)

Type declaration

    • (value?): void
    • Parameters

      • Optional value: void

      Returns void

onerror: ((error) => void)

Type declaration

    • (error): void
    • Parameters

      Returns void

password: string
platform?: string
port: number
socket?: Socket
textEncoder: TextEncoder = ...

Used for string -> arraybuffer when publishing

tls: boolean
tlsOptions: undefined | AMQPTlsOptions
username: string
vhost: string

Methods

  • Gracefully close the AMQP connection

    Parameters

    • Optional reason: string = ""

      might be logged by the server

    • code: number = 200

    Returns Promise<void>

  • Returns Promise<AMQPBaseClient>

  • Parameters

    • newSecret: string
    • reason: string

    Returns Promise<unknown>

Generated using TypeDoc