Interface WorkerProOptions

Hierarchy

  • WorkerOptions
    • WorkerProOptions

Properties

autorun? batch? blockingConnection? concurrency? connection? drainDelay? group? limiter? lockDuration? lockRenewTime? maxStalledCount? metrics? prefix? removeOnComplete? removeOnFail? runRetryDelay? settings? skipLockRenewal? skipStalledCheck? skipVersionCheck? stalledInterval? ttl? useWorkerThreads?

Properties

Optional autorun

autorun?: boolean

Condition to start processor at instance creation.

Default

true

Optional batch

batch?: {
    size?: number;
}

Type declaration

Optional blockingConnection

blockingConnection?: boolean

Denotes commands should retry indefinitely.

Optional concurrency

concurrency?: number

Amount of jobs that a single worker is allowed to work on in parallel.

Default

1

See

https://docs.bullmq.io/guide/workers/concurrency

Optional connection

connection?: ConnectionOptions

Options for connecting to a Redis instance.

Optional drainDelay

drainDelay?: number

Number of seconds to long poll for jobs when the queue is empty.

Default

5

Optional group

group?: {
    concurrency?: number;
    limit?: {
        duration: number;
        max: number;
    };
}

Type declaration

  • Optional concurrency?: number

    Maximum number of simultaneous jobs that the workers can handle within a specific group. For instance, setting this value to 1 ensures that no more than one job from the same group is processed at any given time. If this limit is not defined, there will be no restriction on the number of concurrent jobs.

    See

    https://docs.bullmq.io/bullmq-pro/groups/concurrency

  • Optional limit?: {
        duration: number;
        max: number;
    }
    • duration: number
    • max: number

Optional limiter

limiter?: RateLimiterOptions

Enable rate limiter

See

https://docs.bullmq.io/guide/rate-limiting

Optional lockDuration

lockDuration?: number

Duration of the lock for the job in milliseconds. The lock represents that a worker is processing the job. If the lock is lost, the job will be eventually be picked up by the stalled checker and move back to wait so that another worker can process it again.

Default

30000

Optional lockRenewTime

lockRenewTime?: number

The time in milliseconds before the lock is automatically renewed.

It is not recommended to modify this value, which is by default set to halv the lockDuration value, which is optimal for most use cases.

Optional maxStalledCount

maxStalledCount?: number

Amount of times a job can be recovered from a stalled state to the wait state. If this is exceeded, the job is moved to failed.

Default

1

Optional metrics

metrics?: MetricsOptions

Enable collect metrics.

See

https://docs.bullmq.io/guide/metrics

Optional prefix

prefix?: string

Prefix for all queue keys.

Optional removeOnComplete

removeOnComplete?: KeepJobs

You can provide an object specifying max age and/or count to keep. Default behavior is to keep the job in the completed set.

Optional removeOnFail

removeOnFail?: KeepJobs

You can provide an object specifying max age and/or count to keep. Default behavior is to keep the job in the failed set.

Optional runRetryDelay

runRetryDelay?: number

This is an internal option that should not be modified.

Default

15000

Optional settings

settings?: AdvancedOptions

More advanced options.

Optional skipLockRenewal

skipLockRenewal?: boolean

Skip lock renewal for this worker. If set to true, the lock will expire after lockDuration and moved back to the wait queue (if the stalled check is not disabled)

Default

false

Optional skipStalledCheck

skipStalledCheck?: boolean

Skip stalled check for this worker. Note that other workers could still perform stalled checkd and move jobs back to wait for jobs being processed by this worker.

Default

false

Optional skipVersionCheck

skipVersionCheck?: boolean

Avoid version validation to be greater or equal than v5.0.0.

Default Value

false

Optional stalledInterval

stalledInterval?: number

Number of milliseconds between stallness checks.

Default

30000

Optional ttl

ttl?: number | JobTtlMap

Optional useWorkerThreads

useWorkerThreads?: boolean

Use Worker Threads instead of Child Processes. Note: This option can only be used when specifying a file for the processor argument.

Default

false

Settings

Member Visibility

Theme

On This Page

Generated using TypeDoc