Interface AMQPQueueLike

Readonlyname

bind

• bind(
      exchange: string,
      routingKey?: string,
      args?: Record<string, unknown>,
  ): Promise<unknown>

  Parameters

  • exchange: string
  • OptionalroutingKey: string
  • Optionalargs: Record<string, unknown>

  Returns Promise<unknown>

consumeOne

• consumeOne(options?: { timeout?: number }): Promise<AMQPMessage<{}>>

  Parameters

  • Optionaloptions: { timeout?: number }

  Returns Promise<AMQPMessage<{}>>

get

• get(params?: { noAck?: boolean }): Promise<null | AMQPMessage<{}>>

  Parameters

  • Optionalparams: { noAck?: boolean }

  Returns Promise<null | AMQPMessage<{}>>

publish

• publish(
      body: unknown,
      options?: AMQPProperties & { confirm?: boolean; mandatory?: boolean },
  ): Promise<unknown>

  Parameters

  • body: unknown
  • Optionaloptions: AMQPProperties & { confirm?: boolean; mandatory?: boolean }

  Returns Promise<unknown>

subscribe

• subscribe(
      params: QueueSubscribeParams,
      callback: (msg: AMQPMessage) => void | Promise<void>,
  ): Promise<AMQPSubscriptionLike>

  Parameters

  • params: QueueSubscribeParams
  • callback: (msg: AMQPMessage) => void | Promise<void>

  Returns Promise<AMQPSubscriptionLike>