Options
All
  • Public
  • Public/Protected
  • All
Menu

Class DirectExchange

Represents a direct exchange

Hierarchy

  • StringRoutingExchange
    • DirectExchange

Index

Methods

Methods

bind

  • bind(dest: Exchange | Queue<any>, routingKey: string | string[]): void

  • Bind an exchange or queue

    Parameters

    • dest: Exchange | Queue<any>
    • routingKey: string | string[]

      Single routing key or list of routing keys

    Returns void

consume

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

    Type parameters

    • T

    Parameters

    • name: string
    • mw: ConsumeMiddleware<T>
    • routingKey: string | string[]

      Single routing key or list of routing keys

    Returns void

  • Create and bind a temporary queue and start consuming in the provided middleware

    Type parameters

    • T

    Parameters

    • mw: ConsumeMiddleware<T>
    • routingKey: string | string[]

      Single routing key or list of routing keys

    Returns void

direct

  • Create and bind an internal direct exchange

    Parameters

    • name: string
    • routingKey: string | string[]

      Single routing key or list of routing keys

    Returns DirectExchange

exchange

  • exchange(name: string, exType: string, routingKey: string | string[]): CustomExchange

  • Create and bind an internal exchange with custom type

    Parameters

    • name: string
    • exType: string
    • routingKey: string | string[]

      Single routing key or list of routing keys

    Returns CustomExchange

fanout

  • Create and bind an internal fanout exchange

    Parameters

    • name: string
    • routingKey: string | string[]

      Single routing key or list of routing keys

    Returns FanoutExchange

headers

  • Create and bind an internal headers exchange

    Parameters

    • name: string
    • routingKey: string | string[]

      Single routing key or list of routing keys

    Returns HeadersExchange

topic

  • topic(name: string, routingKey: string | string[]): TopicExchange

  • Create and bind an internal topic exchange

    Parameters

    • name: string
    • routingKey: string | string[]

      Single routing key or list of routing keys

    Returns TopicExchange

Generated using TypeDoc