Class FanoutExchange

Represents a fanout exchange

Hierarchy

BaseExchange
- FanoutExchange

Index

Methods

Methods

bind

bind(dest: Exchange | Queue<any>): void

Bind an exchange or queue

Parameters
- dest: Exchange | Queue<any>
Returns void

consume

consume<T>(name: string, mw: ConsumeMiddleware<T>): void
consume<T>(mw: ConsumeMiddleware<T>): void

Create and bind a named queue and start consuming in the provided middleware

Type parameters
- T
Parameters
- name: string
- mw: ConsumeMiddleware<T>
Returns void
Create and bind a temporary queue and start consuming in the provided middleware

Type parameters
- T
Parameters
- mw: ConsumeMiddleware<T>
Returns void

direct

direct(name: string): DirectExchange

Create and bind an internal direct exchange

Parameters
- name: string
Returns DirectExchange

exchange

exchange(name: string, exType: string): CustomExchange

Create and bind an internal exchange with custom type

Parameters
- name: string
- exType: string
Returns CustomExchange

fanout

fanout(name: string): FanoutExchange

Create and bind an internal fanout exchange

Parameters
- name: string
Returns FanoutExchange

headers

headers(name: string): HeadersExchange

Create and bind an internal headers exchange

Parameters
- name: string
Returns HeadersExchange

topic

topic(name: string): TopicExchange

Create and bind an internal topic exchange

Parameters
- name: string
Returns TopicExchange

Generated using TypeDoc