Class Queue<T>

subscribe

• subscribe(ex: FanoutExchange): Queue<T>
• subscribe(ex: DirectExchange, routingKey: string | string[]): Queue<T>
• subscribe(ex: TopicExchange, routingKey: string | string[]): Queue<T>
• subscribe(ex: HeadersExchange, routingHeaders: IRoutingHeaders): Queue<T>
• subscribe(ex: CustomExchange, routingKey?: string, args?: IArguments): Queue<T>

• Subscribe to the fanout exchange

  Parameters

  • ex: FanoutExchange

  Returns Queue<T>

• Subscribe to the direct exchange

  Parameters

  • ex: DirectExchange

  • routingKey: string | string[]

  Returns Queue<T>

• Subscribe to the topic exchange

  Parameters

  • ex: TopicExchange

  • routingKey: string | string[]

  Returns Queue<T>

• Subscribe to the headers exchange

  Parameters

  • ex: HeadersExchange

  • routingHeaders: IRoutingHeaders

  Returns Queue<T>

• Subscribe to the exchange with custom type

  Parameters

  • ex: CustomExchange

  • Optional routingKey: string

  • Optional args: IArguments

  Returns Queue<T>