Class AMQPExchange<P, C, KP, KC>

Readonlyname

bind

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

  Bind this exchange to a source exchange.

  Parameters

  • source: string | AMQPExchange<P, C, KP, KC>

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

  Returns Promise<AMQPExchange<P, C, KP, KC>>

  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<O extends string = KP>(
      body: ResolveBody<P, O>,
      options?: ExchangePublishOptions<O>,
  ): Promise<AMQPExchange<P, C, KP, KC>>

  Publish a message to this exchange.

  When the session has parsers configured, body can be any value accepted by the matching parser's serialize method. Without parsers, body must be a string, Buffer, Uint8Array, or null.

  Defaults: confirm: true, deliveryMode: 2 (persistent). Pass deliveryMode: 1 to send a transient message.

  Type Parameters

  • O extends string = KP

  Parameters

  • body: ResolveBody<P, O>
  • options: ExchangePublishOptions<O> = {}

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

  Returns Promise<AMQPExchange<P, C, KP, KC>>

  this for chaining

unbind

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

  Remove a binding between this exchange and a source exchange.

  Parameters

  • source: string | AMQPExchange<P, C, KP, KC>

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

  Returns Promise<AMQPExchange<P, C, KP, KC>>

  this for chaining