Class Queue<T>

constructor

• new Queue<T = DatabaseClient>(params: QueueParams<T>): Queue<T>

  Type Parameters

  • T = DatabaseClient

  Parameters

  • params: QueueParams<T>

  Returns Queue<T>

Readonlymessage

Readonlyschema

channel

• channel(channelId: string): QueueChannelModule<T>

  Parameters

  • channelId: string

  Returns QueueChannelModule<T>

dequeue

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

  Parameters

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

  Returns Promise<QueueMessageDequeueResult<T>>

install

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

  Parameters

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

  Returns string[]

Staticdecode

• decode(payload: string): QueueEvent

  Parameters

  • payload: string

  Returns QueueEvent