Interface Exchange<TMessage>

metaType

alternateExchange

• alternateExchange(alternateExchange): Exchange<TMessage>

• send all unrouted messages to this exchange

  Parameters

  • alternateExchange: string | Exchange<unknown>

  Returns Exchange<TMessage>

autoDelete

• autoDelete(autoDelete?): Exchange<TMessage>

• if true, the exchange will be destroyed once the number of bindings for which it is the source drop to zero. Defaults to false.

  Parameters

  • Optional autoDelete: boolean

  Returns Exchange<TMessage>

delayed

• delayed(xDelayedType): Exchange<TMessage>

• Set the exchange type as 'delayed' and x-delayed-type attribute as the specified

  Parameters

  • xDelayedType: StandardExchangeType

  Returns Exchange<TMessage>

direct

• direct(): Exchange<TMessage>

• Set the exchange type as 'direct'

  Returns Exchange<TMessage>

durable

• durable(durable?): Exchange<TMessage>

• if true, the exchange will survive broker restarts. Defaults to true

  Parameters

  • Optional durable: boolean

  Returns Exchange<TMessage>

fanout

• fanout(): Exchange<TMessage>

• Set the exchange type as 'fanout'

  Returns Exchange<TMessage>

getName

• getName(): string

• Returns string

getOpts

• getOpts(): ExchangeOptions

• Returns ExchangeOptions

getType

• getType(): ExchangeType

• Returns ExchangeType

headers

• headers(): Exchange<TMessage>

• Set the exchange type as 'headers'

  Returns Exchange<TMessage>

passive

• passive(passive?): Exchange<TMessage>

• Use checkExchange instead of assertExchange for setup

  Parameters

  • Optional passive: boolean

  Returns Exchange<TMessage>

topic

• topic(): Exchange<TMessage>

• Set the exchange type as 'topic'

  Returns Exchange<TMessage>