Options
All
  • Public
  • Public/Protected
  • All
Menu

Interface AMQPExchange

Hierarchy

  • EventEmitter
    • AMQPExchange

Index

Methods

Methods

addListener

  • addListener(event: string | symbol, listener: (...args: any[]) => void): AMQPExchange

  • Parameters

    • event: string | symbol
    • listener: (...args: any[]) => void
        • (...args: any[]): void

        • Parameters

          • Rest ...args: any[]

          Returns void

    Returns AMQPExchange

bind

  • bind(sourceExchange: string, routingKey: string, callback?: Callback<void>): void

  • Parameters

    • sourceExchange: string
    • routingKey: string
    • Optional callback: Callback<void>

    Returns void

bind_headers

  • bind_headers(exchange: string, routing: string, callback?: Callback<void>): void

  • Parameters

    • exchange: string
    • routing: string
    • Optional callback: Callback<void>

    Returns void

destroy

  • destroy(ifUnused: boolean): void

  • ifUnused default: true

    Deletes an exchange.

    If the optional boolean second argument is set, the server will only delete the exchange if it has no queue bindings.

    If the exchange has queue bindings the server does not delete it but raises a channel exception instead

    Parameters

    • ifUnused: boolean

    Returns void

emit

  • emit(event: string | symbol, ...args: any[]): boolean

  • Parameters

    • event: string | symbol
    • Rest ...args: any[]

    Returns boolean

eventNames

  • eventNames(): (string | symbol)[]

  • Returns (string | symbol)[]

getMaxListeners

  • getMaxListeners(): number

  • Returns number

listenerCount

  • listenerCount(event: string | symbol): number

  • Parameters

    • event: string | symbol

    Returns number

listeners

  • listeners(event: string | symbol): Function[]

  • Parameters

    • event: string | symbol

    Returns Function[]

off

  • off(event: string | symbol, listener: (...args: any[]) => void): AMQPExchange

  • Parameters

    • event: string | symbol
    • listener: (...args: any[]) => void
        • (...args: any[]): void

        • Parameters

          • Rest ...args: any[]

          Returns void

    Returns AMQPExchange

on

  • on(event: "error" | "open" | "ack" | "exchangeBindOk" | "exchangeUnbindOk", callback: Callback<void>): AMQPExchange

  • Parameters

    • event: "error" | "open" | "ack" | "exchangeBindOk" | "exchangeUnbindOk"
    • callback: Callback<void>

    Returns AMQPExchange

once

  • once(event: string | symbol, listener: (...args: any[]) => void): AMQPExchange

  • Parameters

    • event: string | symbol
    • listener: (...args: any[]) => void
        • (...args: any[]): void

        • Parameters

          • Rest ...args: any[]

          Returns void

    Returns AMQPExchange

prependListener

  • prependListener(event: string | symbol, listener: (...args: any[]) => void): AMQPExchange

  • Parameters

    • event: string | symbol
    • listener: (...args: any[]) => void
        • (...args: any[]): void

        • Parameters

          • Rest ...args: any[]

          Returns void

    Returns AMQPExchange

prependOnceListener

  • prependOnceListener(event: string | symbol, listener: (...args: any[]) => void): AMQPExchange

  • Parameters

    • event: string | symbol
    • listener: (...args: any[]) => void
        • (...args: any[]): void

        • Parameters

          • Rest ...args: any[]

          Returns void

    Returns AMQPExchange

publish

  • publish(routingKey: string, message: {} | Buffer, callback: (err?: boolean, msg?: string) => void): void
  • publish(routingKey: string, message: {} | Buffer, options: ExchangePublishOptions, callback?: (err?: boolean, msg?: string) => void): void

  • Parameters

    • routingKey: string
    • message: {} | Buffer
    • callback: (err?: boolean, msg?: string) => void
        • (err?: boolean, msg?: string): void

        • Parameters

          • Optional err: boolean
          • Optional msg: string

          Returns void

    Returns void

  • Parameters

    • routingKey: string
    • message: {} | Buffer
    • options: ExchangePublishOptions
    • Optional callback: (err?: boolean, msg?: string) => void
        • (err?: boolean, msg?: string): void

        • Parameters

          • Optional err: boolean
          • Optional msg: string

          Returns void

    Returns void

rawListeners

  • rawListeners(event: string | symbol): Function[]

  • Parameters

    • event: string | symbol

    Returns Function[]

removeAllListeners

  • Parameters

    • Optional event: string | symbol

    Returns AMQPExchange

removeListener

  • removeListener(event: string | symbol, listener: (...args: any[]) => void): AMQPExchange

  • Parameters

    • event: string | symbol
    • listener: (...args: any[]) => void
        • (...args: any[]): void

        • Parameters

          • Rest ...args: any[]

          Returns void

    Returns AMQPExchange

setMaxListeners

  • Parameters

    • n: number

    Returns AMQPExchange

unbind

  • unbind(sourceExchange: string, routingKey: string, callback?: Callback<void>): void

  • Parameters

    • sourceExchange: string
    • routingKey: string
    • Optional callback: Callback<void>

    Returns void

Generated using TypeDoc