Class CustomExchange

Represents an exchange with custom type

Hierarchy

BaseExchange
- CustomExchange

Index

Methods

Methods

bind

bind(dest: Exchange | Queue<any>, routingKey?: string, args?: IArguments): void

Bind an exchange or queue

Parameters
- dest: Exchange | Queue<any>
- Optional routingKey: string
- Optional args: IArguments
Returns void

consume

consume<T>(name: string, mw: ConsumeMiddleware<T>, routingKey?: string, routingArgs?: IArguments): void
consume<T>(mw: ConsumeMiddleware<T>, routingKey?: string, routingArgs?: IArguments): void

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

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

Type parameters
- T
Parameters
- mw: ConsumeMiddleware<T>
- Optional routingKey: string
- Optional routingArgs: IArguments
Returns void

direct

direct(name: string, routingKey?: string, args?: IArguments): DirectExchange

Create and bind an internal direct exchange

Parameters
- name: string
- Optional routingKey: string
- Optional args: IArguments
Returns DirectExchange

exchange

exchange(name: string, exType: string, routingKey?: string, args?: IArguments): CustomExchange

Create and bind an internal exchange with custom type

Parameters
- name: string
- exType: string
- Optional routingKey: string
- Optional args: IArguments
Returns CustomExchange

fanout

fanout(name: string, routingKey?: string, args?: IArguments): FanoutExchange

Create and bind an internal fanout exchange

Parameters
- name: string
- Optional routingKey: string
- Optional args: IArguments
Returns FanoutExchange

headers

headers(name: string, routingKey?: string, args?: IArguments): HeadersExchange

Create and bind an internal headers exchange

Parameters
- name: string
- Optional routingKey: string
- Optional args: IArguments
Returns HeadersExchange

topic

topic(name: string, routingKey?: string, args?: IArguments): TopicExchange

Create and bind an internal topic exchange

Parameters
- name: string
- Optional routingKey: string
- Optional args: IArguments
Returns TopicExchange

Generated using TypeDoc