OptionalautorunCondition to start processor at instance creation.
OptionalblockingDenotes commands should retry indefinitely.
OptionalconcurrencyAmount of jobs that a single worker is allowed to work on in parallel.
OptionalconnectionOptions for connecting to a Redis instance.
OptionaldrainNumber of seconds to long poll for jobs when the queue is empty.
OptionallimiterEnable rate limiter
OptionallockDuration 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.
OptionallockThe 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.
OptionalmaxAmount 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.
OptionalmetricsEnable collect metrics.
OptionalprefixPrefix for all queue keys.
OptionalremoveYou can provide an object specifying max age and/or count to keep. Default behavior is to keep the job in the completed set.
OptionalremoveYou can provide an object specifying max age and/or count to keep. Default behavior is to keep the job in the failed set.
OptionalrunThis is an internal option that should not be modified.
OptionalsettingsMore advanced options.
OptionalsharedSpecify if the connection is shared.
OptionalskipSkip 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)
OptionalskipSkip 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.
OptionalstalledNumber of milliseconds between stallness checks.
OptionaluseUse Worker Threads instead of Child Processes. Note: This option can only be used when specifying a file for the processor argument.
Base Queue options