Class Exchange

Abstraction over AMQP exchange operations on a Channel.

Hierarchy

Exchange

Index

Constructors

constructor

Properties

Methods

Constructors

constructor

new Exchange(channel: Channel, name: string): Exchange

- Defined in src/exchange.ts:21
Parameters
- channel: Channel
  
  AMQP channel from amqplib
- name: string
  
  Exchange name
Returns Exchange

Properties

Private #channel

#channel: Channel

Private #name

#name: string

Methods

bind

bind(source: string, pattern: string, args?: any): Promise<void>

- Defined in src/exchange.ts:56
Bind an exchange to this exchange.

Will call Channel.bindExchange.

Parameters
- source: string
- pattern: string
- Optional args: any
Returns Promise<void>

check

check(): Promise<void>

- Defined in src/exchange.ts:38
Check that the exchange exists. If it doesn’t exist, the channel will be closed with an error. If it does exist, happy days.

Will call Channel.checkExchange.

Returns Promise<void>

remove

remove(options: DeleteExchange): Promise<void>

- Defined in src/exchange.ts:47
Delete this exchange.

Will call Channel.deleteExchange.

Parameters
- options: DeleteExchange
Returns Promise<void>

unbind

unbind(source: string, pattern: string, args?: any): Promise<void>

- Defined in src/exchange.ts:65
Unind an exchange from this exchange.

Will call Channel.unbindExchange.

Parameters
- source: string
- pattern: string
- Optional args: any
Returns Promise<void>

Generated using TypeDoc