Class HeadersExchange

Represents a headers exchange

Hierarchy

BaseExchange
- HeadersExchange

Index

Methods

Methods

bind

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

Bind an exchange or queue

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

consume

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

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

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

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

direct

direct(name: string, routingHeaders: IRoutingHeaders): DirectExchange

Create and bind an internal direct exchange

Parameters
- name: string
- routingHeaders: IRoutingHeaders
Returns DirectExchange

exchange

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

Create and bind an internal exchange with custom type

Parameters
- name: string
- exType: string
- routingHeaders: IRoutingHeaders
Returns CustomExchange

fanout

fanout(name: string, routingHeaders: IRoutingHeaders): FanoutExchange

Create and bind an internal fanout exchange

Parameters
- name: string
- routingHeaders: IRoutingHeaders
Returns FanoutExchange

headers

headers(name: string, routingHeaders: IRoutingHeaders): HeadersExchange

Create and bind an internal headers exchange

Parameters
- name: string
- routingHeaders: IRoutingHeaders
Returns HeadersExchange

topic

topic(name: string, routingHeaders: IRoutingHeaders): TopicExchange

Create and bind an internal topic exchange

Parameters
- name: string
- routingHeaders: IRoutingHeaders
Returns TopicExchange

Generated using TypeDoc