Class Worker<DataType, ResultType, NameType>

constructor

• new Worker<DataType, ResultType, NameType>(name, processor?, opts?, Connection?): Worker<DataType, ResultType, NameType>

• Type Parameters

  • DataType = any
  • ResultType = any
  • NameType extends string = string

  Parameters

  • name: string
  • Optional processor: string | URL | Processor<DataType, ResultType, NameType>
  • Optional opts: WorkerOptions
  • Optional Connection: typeof RedisConnection

  Returns Worker<DataType, ResultType, NameType>

Readonly id

Readonly opts

concurrency

• set concurrency(concurrency): void

• Parameters

  • concurrency: number

  Returns void

minimumBlockTimeout

• get minimumBlockTimeout(): number

• Returns number

repeat

• get repeat(): Promise<Repeat>

• Returns Promise<Repeat>

close

• close(force?): Promise<void>

• Closes the worker and related redis connections.

  This method waits for current jobs to finalize before returning.

  Parameters

  • force: boolean = false

    Use force boolean parameter if you do not want to wait for current jobs to be processed.

  Returns Promise<void>

  Promise that resolves when the worker has been closed.

delay

• delay(milliseconds?, abortController?): Promise<void>

• This function is exposed only for testing purposes.

  Parameters

  • Optional milliseconds: number
  • Optional abortController: AbortController

  Returns Promise<void>

emit

• emit<U>(event, ...args): boolean

• Emits an event. Normally used by subclasses to emit events.

  Type Parameters

  • U extends keyof WorkerListener<DataType, ResultType, NameType>

  Parameters

  • event: U

    The emitted event.
  • Rest ...args: Parameters<WorkerListener<DataType, ResultType, NameType>[U]>

  Returns boolean

getNextJob

• getNextJob(token, __namedParameters?): Promise<Job<DataType, ResultType, NameType>>

• Returns a promise that resolves to the next job in queue.

  Parameters

  • token: string

    worker token to be assigned to retrieved job
  • __namedParameters: GetNextJobOptions = {}

  Returns Promise<Job<DataType, ResultType, NameType>>

  a Job or undefined if no job was available in the queue.

isPaused

• isPaused(): boolean

• Checks if worker is paused.

  Returns boolean

  true if worker is paused, false otherwise.

isRunning

• isRunning(): boolean

• Checks if worker is currently running.

  Returns boolean

  true if worker is running, false otherwise.

off

• off<U>(eventName, listener): this

• Type Parameters

  • U extends keyof WorkerListener<DataType, ResultType, NameType>

  Parameters

  • eventName: U
  • listener: WorkerListener<DataType, ResultType, NameType>[U]

  Returns this

on

• on<U>(event, listener): this

• Type Parameters

  • U extends keyof WorkerListener<DataType, ResultType, NameType>

  Parameters

  • event: U
  • listener: WorkerListener<DataType, ResultType, NameType>[U]

  Returns this

once

• once<U>(event, listener): this

• Type Parameters

  • U extends keyof WorkerListener<DataType, ResultType, NameType>

  Parameters

  • event: U
  • listener: WorkerListener<DataType, ResultType, NameType>[U]

  Returns this

pause

• pause(doNotWaitActive?): Promise<void>

• Pauses the processing of this queue only for this worker.

  Parameters

  • Optional doNotWaitActive: boolean

  Returns Promise<void>

processJob

• processJob(job, token, fetchNextCallback?, jobsInProgress): Promise<void | Job<DataType, ResultType, NameType>>

• Parameters

  • job: Job<DataType, ResultType, NameType>
  • token: string
  • fetchNextCallback: (() => boolean) = ...
    • • (): boolean

      • Returns boolean

  • jobsInProgress: Set<{
        job: Job<any, any, string>;
        ts: number;
    }>

  Returns Promise<void | Job<DataType, ResultType, NameType>>

rateLimit

• rateLimit(expireTimeMs): Promise<void>

• Overrides the rate limit to be active for the next jobs.

  Parameters

  • expireTimeMs: number

    expire time in ms of this rate limit.

  Returns Promise<void>

resume

• resume(): void

• Resumes processing of this worker (if paused).

  Returns void

run

• run(): Promise<void>

• Returns Promise<void>

startStalledCheckTimer

• startStalledCheckTimer(): Promise<void>

• Manually starts the stalled checker. The check will run once as soon as this method is called, and then every opts.stalledInterval milliseconds until the worker is closed. Note: Normally you do not need to call this method, since the stalled checker is automatically started when the worker starts processing jobs after calling run. However if you want to process the jobs manually you need to call this method to start the stalled checker.

  Returns Promise<void>

  See

  https://docs.bullmq.io/patterns/manually-fetching-jobs

waitUntilReady

• waitUntilReady(): Promise<RedisClient>

• Waits until the worker is ready to start processing jobs. In general only useful when writing tests.

  Returns Promise<RedisClient>

Static RateLimitError

• RateLimitError(): Error

• Returns Error