Class Queue<T>

constructor

• new Queue<T = Client>(params: Params<T>): queue.Queue<T>

  Type Parameters

  • T = Client

  Parameters

  • params: Params<T>

  Returns queue.Queue<T>

Readonlymessage

Readonlyschema

channel

• channel(channelId: string): queue.module.Channel<T>

  Parameters

  • channelId: string

  Returns queue.module.Channel<T>

dequeue

• dequeue(
      params: { databaseClient: T; lockMs: number },
  ): Promise<DequeueResult<T>>

  Parameters

  • params: { databaseClient: T; lockMs: number }

  Returns Promise<DequeueResult<T>>

install

• install(params?: { eventChannel?: string }): string[]

  Parameters

  • params: { eventChannel?: string } = {}

  Returns string[]

Staticdecode

• decode(payload: string): DecodeResult

  Parameters

  • payload: string

  Returns DecodeResult