Class QueueGroup

constructor

• new QueueGroup(namespace: string): QueueGroup

  Parameters

  • namespace: string

  Returns QueueGroup

Readonlyprefix

drainAll

• drainAll(): void

  Drain all queues in this group (remove waiting jobs)

  Returns void

getQueue

• getQueue<T = unknown>(name: string, opts?: QueueOptions): Queue<T>

  Get a queue within this group

  Type Parameters

  • T = unknown

  Parameters

  • name: string
  • Optionalopts: QueueOptions

  Returns Queue<T>

getWorker

• getWorker<T = unknown, R = unknown>(
      name: string,
      processor: Processor<T, R>,
      opts?: WorkerOptions,
  ): Worker<T, R>

  Create a worker for a queue in this group

  Type Parameters

  • T = unknown
  • R = unknown

  Parameters

  • name: string
  • processor: Processor<T, R>
  • Optionalopts: WorkerOptions

  Returns Worker<T, R>

listQueues

• listQueues(): string[]

  List all queues in this group

  Returns string[]

obliterateAll

• obliterateAll(): void

  Obliterate all queues in this group (remove all data)

  Returns void

pauseAll

• pauseAll(): void

  Pause all queues in this group

  Returns void

resumeAll

• resumeAll(): void

  Resume all queues in this group

  Returns void