@cloudamqp/amqp-client
    Preparing search index...

    Class AMQPClient

    AMQP 0-9-1 client over TCP socket.

    Hierarchy

    • AMQPBaseClient
      • AMQPClient
    Index

    Constructors

    constructor

    Properties

    blocked? bufferPool channelMax channels closed closePromise? connectPromise? frameMax heartbeat host logger name? onerror onUpdateSecretOk? password platform? port socket? textEncoder tls tlsOptions username vhost

    Methods

    channel close closeSocket connect updateSecret

    Constructors

    Properties

    blocked?: string
    bufferPool: AMQPView[] = []
    channelMax: number = 0
    channels: AMQPChannel[]
    closed: boolean = true
    closePromise?: [(value?: void) => void, (err: Error) => void]
    connectPromise?: [(conn: AMQPBaseClient) => void, (err: Error) => void]
    frameMax: number
    heartbeat: number
    host: string
    logger: undefined | null | Logger = console
    name?: string
    onerror: (error: AMQPError) => void
    onUpdateSecretOk?: (value?: void) => 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

      • Optionalreason: string = ""

        might be logged by the server

      • code: number = 200

      Returns Promise<void>

    • Try establish a connection

      Returns Promise<AMQPBaseClient>

    • Parameters

      • newSecret: string
      • reason: string

      Returns Promise<unknown>

    Settings

    Member Visibility

    On This Page

    Constructors
    Properties
    Methods