Class AMQPExchange

Readonlyname

bind

• bind(
      source: string | AMQPExchange,
      routingKey?: string,
      args?: Record<string, unknown>,
  ): Promise<AMQPExchange>

  Bind this exchange to a source exchange.

  Parameters

  • source: string | AMQPExchange

    name or AMQPExchange to bind from
  • routingKey: string = ""
  • args: Record<string, unknown> = {}

  Returns Promise<AMQPExchange>

  this for chaining

delete

• delete(params?: { ifUnused?: boolean }): Promise<void>

  Delete this exchange.

  Parameters

  • Optionalparams: { ifUnused?: boolean }

    • OptionalifUnused?: boolean

      only delete if the exchange has no bindings

  Returns Promise<void>

publish

• publish(body: Body, options?: ExchangePublishOptions): Promise<AMQPExchange>

  Publish a message to this exchange.

  Parameters

  • body: Body
  • options: ExchangePublishOptions = {}

    routing key, publish properties; set confirm: false to skip broker confirmation

  Returns Promise<AMQPExchange>

  this for chaining

unbind

• unbind(
      source: string | AMQPExchange,
      routingKey?: string,
      args?: Record<string, unknown>,
  ): Promise<AMQPExchange>

  Remove a binding between this exchange and a source exchange.

  Parameters

  • source: string | AMQPExchange

    name or AMQPExchange to unbind from
  • routingKey: string = ""
  • args: Record<string, unknown> = {}

  Returns Promise<AMQPExchange>

  this for chaining