bullmq - v5.51.1
v2
Module v2
Enumerations
ChildCommand
ClientType
ErrorCode
MetricsTime
ParentCommand
Classes
Backoffs
ChildPool
ChildProcessor
FlowProducer
Job
Queue
QueueBase
QueueEvents
QueueGetters
QueueKeys
RedisConnection
Repeat
ScriptLoader
ScriptLoaderError
Scripts
TimerManager
UnrecoverableError
Worker
Interfaces
AddChildrenOpts
AddNodeOpts
AdvancedOptions
AdvancedRepeatOptions
BackoffOptions
BaseJobOptions
ChildMessage
ChildProcessExt
Command
DefaultJobOptions
DependenciesOpts
FlowOpts
FlowProducerListener
GetNextJobOptions
IConnection
IoredisListener
JobJson
JobJsonRaw
JobNode
KeepJobs
Metrics
MetricsOptions
MoveToWaitingChildrenOpts
NodeOpts
ObliterateOpts
Parent
ParentKeys
ParentMessage
QueueBaseOptions
QueueEventsListener
QueueEventsOptions
QueueListener
QueueOptions
RateLimiterOptions
RawCommand
RepeatBaseOptions
RepeatOptions
SandboxedJob
ScriptMetadata
Strategies
WorkerListener
WorkerOptions
Type Aliases
BackoffFunction
BulkJobOptions
ClusterOptions
ConnectionOptions
EntryId
EntryRaw
FinishedPropValAttribute
FinishedStatus
FlowChildJob
FlowJob
FlowQueuesOpts
JobData
JobJsonSandbox
JobsOptions
JobState
JobType
KeysMap
MinimalQueue
ParentOpts
Processor
RedisClient
RedisJobOptions
RedisOptions
RepeatStrategy
SandboxedJobProcessor
StreamName
StreamReadRaw
Variables
clientCommandMessageReg
DELAY_TIME_1
DELAY_TIME_5
errorObject
QUEUE_EVENT_SUFFIX
QUEUE_SCHEDULER_SUFFIX
scriptLoader
WORKER_SUFFIX
Functions
array2obj
asyncSend
childSend
delay
getNextMillis
getParentKey
isEmpty
isNotConnectionError
isRedisCluster
isRedisInstance
isRedisVersionLowerThan
jobIdForGroup
killAsync
lengthInUtf8Bytes
parentSend
raw2jobData
removeAllQueueData
tryCatch
Settings
Member Visibility
Inherited
Theme
OS
Light
Dark
On This Page
Enumerations
Child
Command
Client
Type
Error
Code
Metrics
Time
Parent
Command
Classes
Backoffs
Child
Pool
Child
Processor
Flow
Producer
Job
Queue
Queue
Base
Queue
Events
Queue
Getters
Queue
Keys
Redis
Connection
Repeat
Script
Loader
Script
Loader
Error
Scripts
Timer
Manager
Unrecoverable
Error
Worker
Interfaces
Add
Children
Opts
Add
Node
Opts
Advanced
Options
Advanced
Repeat
Options
Backoff
Options
Base
Job
Options
Child
Message
Child
Process
Ext
Command
Default
Job
Options
Dependencies
Opts
Flow
Opts
Flow
Producer
Listener
Get
Next
Job
Options
IConnection
Ioredis
Listener
Job
Json
Job
Json
Raw
Job
Node
Keep
Jobs
Metrics
Metrics
Options
Move
To
Waiting
Children
Opts
Node
Opts
Obliterate
Opts
Parent
Parent
Keys
Parent
Message
Queue
Base
Options
Queue
Events
Listener
Queue
Events
Options
Queue
Listener
Queue
Options
Rate
Limiter
Options
Raw
Command
Repeat
Base
Options
Repeat
Options
Sandboxed
Job
Script
Metadata
Strategies
Worker
Listener
Worker
Options
Type Aliases
Backoff
Function
Bulk
Job
Options
Cluster
Options
Connection
Options
Entry
Id
Entry
Raw
Finished
Prop
Val
Attribute
Finished
Status
Flow
Child
Job
Flow
Job
Flow
Queues
Opts
Job
Data
Job
Json
Sandbox
Jobs
Options
Job
State
Job
Type
Keys
Map
Minimal
Queue
Parent
Opts
Processor
Redis
Client
Redis
Job
Options
Redis
Options
Repeat
Strategy
Sandboxed
Job
Processor
Stream
Name
Stream
Read
Raw
Variables
client
Command
Message
Reg
DELAY_
TIME_
1
DELAY_
TIME_
5
error
Object
QUEUE_
EVENT_
SUFFIX
QUEUE_
SCHEDULER_
SUFFIX
script
Loader
WORKER_
SUFFIX
Functions
array2obj
async
Send
child
Send
delay
get
Next
Millis
get
Parent
Key
is
Empty
is
Not
Connection
Error
is
Redis
Cluster
is
Redis
Instance
is
Redis
Version
Lower
Than
job
Id
For
Group
kill
Async
length
In
Utf8
Bytes
parent
Send
raw2job
Data
remove
All
Queue
Data
try
Catch
bullmq - v5.51.1
v1
ChildCommand
ClientType
ErrorCode
MetricsTime
ParentCommand
Backoffs
ChildPool
ChildProcessor
FlowProducer
Job
Queue
Queue3
QueueBase
QueueEvents
QueueGetters
QueueKeys
QueueScheduler
RedisConnection
Repeat
ScriptLoader
ScriptLoaderError
Scripts
TimerManager
UnrecoverableError
Worker
AddChildrenOpts
AddNodeOpts
AdvancedOptions
AdvancedRepeatOptions
BackoffOptions
BaseJobOptions
ChildMessage
ChildProcessExt
Command
DependenciesOpts
FlowJob
FlowOpts
FlowProducerListener
GetNextJobOptions
IConnection
IoredisListener
JobInformation3
JobJson
JobJsonRaw
JobNode
JobPromise3
JobsOptions
KeepJobs
Metrics
MetricsOptions
MoveToWaitingChildrenOpts
NodeOpts
ObliterateOpts
Parent
ParentKeys
ParentMessage
QueueBaseOptions
QueueEventsListener
QueueEventsOptions
QueueListener
QueueOptions
QueueSchedulerListener
QueueSchedulerOptions
RateLimiterOptions
RepeatBaseOptions
RepeatOptions
SandboxedJob
ScriptMetadata
Strategies
WorkerListener
WorkerOptions
ActiveEventCallback3
BackoffFunction
BulkJobOptions
CleanedEventCallback3
ClusterOptions
CompletedEventCallback3
ConnectionOptions
EntryId
EntryRaw
ErrorEventCallback3
EventCallback3
FailedEventCallback3
FinishedPropValAttribute
FinishedStatus
FlowQueuesOpts
JobData
JobJsonSandbox
JobState
JobStatusClean3
JobType
KeysMap
MinimalQueue
ParentOpts
Processor
ProgressEventCallback3
RedisClient
RedisOptions
RemovedEventCallback3
RepeatStrategy
SandboxedJobProcessor
StalledEventCallback3
StreamName
StreamReadRaw
WaitingEventCallback3
clientCommandMessageReg
DELAY_TIME_1
DELAY_TIME_5
errorObject
QUEUE_EVENT_SUFFIX
QUEUE_SCHEDULER_SUFFIX
scriptLoader
WORKER_SUFFIX
array2obj
asyncSend
childSend
delay
getNextMillis
getParentKey
isEmpty
isNotConnectionError
isRedisCluster
isRedisInstance
isRedisVersionLowerThan
jobIdForGroup
killAsync
lengthInUtf8Bytes
parentSend
raw2jobData
removeAllQueueData
tryCatch
v2
ChildCommand
ClientType
ErrorCode
MetricsTime
ParentCommand
Backoffs
ChildPool
ChildProcessor
FlowProducer
Job
Queue
QueueBase
QueueEvents
QueueGetters
QueueKeys
RedisConnection
Repeat
ScriptLoader
ScriptLoaderError
Scripts
TimerManager
UnrecoverableError
Worker
AddChildrenOpts
AddNodeOpts
AdvancedOptions
AdvancedRepeatOptions
BackoffOptions
BaseJobOptions
ChildMessage
ChildProcessExt
Command
DefaultJobOptions
DependenciesOpts
FlowOpts
FlowProducerListener
GetNextJobOptions
IConnection
IoredisListener
JobJson
JobJsonRaw
JobNode
KeepJobs
Metrics
MetricsOptions
MoveToWaitingChildrenOpts
NodeOpts
ObliterateOpts
Parent
ParentKeys
ParentMessage
QueueBaseOptions
QueueEventsListener
QueueEventsOptions
QueueListener
QueueOptions
RateLimiterOptions
RawCommand
RepeatBaseOptions
RepeatOptions
SandboxedJob
ScriptMetadata
Strategies
WorkerListener
WorkerOptions
BackoffFunction
BulkJobOptions
ClusterOptions
ConnectionOptions
EntryId
EntryRaw
FinishedPropValAttribute
FinishedStatus
FlowChildJob
FlowJob
FlowQueuesOpts
JobData
JobJsonSandbox
JobsOptions
JobState
JobType
KeysMap
MinimalQueue
ParentOpts
Processor
RedisClient
RedisJobOptions
RedisOptions
RepeatStrategy
SandboxedJobProcessor
StreamName
StreamReadRaw
clientCommandMessageReg
DELAY_TIME_1
DELAY_TIME_5
errorObject
QUEUE_EVENT_SUFFIX
QUEUE_SCHEDULER_SUFFIX
scriptLoader
WORKER_SUFFIX
array2obj
asyncSend
childSend
delay
getNextMillis
getParentKey
isEmpty
isNotConnectionError
isRedisCluster
isRedisInstance
isRedisVersionLowerThan
jobIdForGroup
killAsync
lengthInUtf8Bytes
parentSend
raw2jobData
removeAllQueueData
tryCatch
v3
ChildCommand
ClientType
ErrorCode
MetricsTime
ParentCommand
AsyncFifoQueue
Backoffs
ChildPool
ChildProcessor
DelayedError
FlowProducer
Job
Queue
QueueBase
QueueEvents
QueueGetters
QueueKeys
RedisConnection
Repeat
ScriptLoader
ScriptLoaderError
Scripts
UnrecoverableError
WaitingChildrenError
Worker
AddChildrenOpts
AddNodeOpts
AdvancedOptions
AdvancedRepeatOptions
BackoffOptions
BaseJobOptions
BaseOptions
BuiltInStrategies
ChildMessage
Command
DefaultJobOptions
DependenciesOpts
FlowJobBase
FlowOpts
FlowProducerListener
GetNextJobOptions
IConnection
IoredisListener
JobJson
JobJsonRaw
JobNode
KeepJobs
Metrics
MetricsOptions
MinimalJob
MoveToWaitingChildrenOpts
NodeOpts
ObliterateOpts
Parent
ParentKeys
ParentMessage
QueueBaseOptions
QueueEventsListener
QueueEventsOptions
QueueListener
QueueOptions
RateLimiterOptions
RawCommand
RepeatBaseOptions
RepeatOptions
SandboxedJob
ScriptMetadata
WorkerListener
WorkerOptions
BackoffStrategy
BulkJobOptions
ClusterOptions
ConnectionOptions
EntryId
EntryRaw
FinishedPropValAttribute
FinishedStatus
FlowChildJob
FlowJob
FlowQueuesOpts
JobData
JobJsonSandbox
JobsOptions
JobState
JobType
KeysMap
MinimalQueue
ParentOpts
Processor
RedisClient
RedisJobOptions
RedisOptions
RepeatStrategy
SandboxedJobProcessor
StreamName
StreamReadRaw
clientCommandMessageReg
DELAY_TIME_1
DELAY_TIME_5
errorObject
QUEUE_EVENT_SUFFIX
scriptLoader
WORKER_SUFFIX
array2obj
asyncSend
childSend
delay
errorToJSON
getNextMillis
getParentKey
isEmpty
isNotConnectionError
isRedisCluster
isRedisInstance
isRedisVersionLowerThan
lengthInUtf8Bytes
parseObjectValues
raw2NextJobData
removeAllQueueData
tryCatch
v4
ChildCommand
ClientType
ErrorCode
MetricsTime
ParentCommand
AsyncFifoQueue
Backoffs
ChildPool
ChildProcessor
DelayedError
FlowProducer
Job
Queue
QueueBase
QueueEvents
QueueGetters
QueueKeys
RateLimitError
RedisConnection
Repeat
ScriptLoader
ScriptLoaderError
Scripts
UnrecoverableError
WaitingChildrenError
Worker
AddChildrenOpts
AddNodeOpts
AdvancedOptions
AdvancedRepeatOptions
BackoffOptions
BaseJobOptions
BaseOptions
BuiltInStrategies
ChildMessage
Command
DefaultJobOptions
DependenciesOpts
FlowJobBase
FlowOpts
FlowProducerListener
GetNextJobOptions
IConnection
IoredisListener
JobJson
JobJsonRaw
JobNode
KeepJobs
Metrics
MetricsOptions
MinimalJob
MoveToWaitingChildrenOpts
NodeOpts
ObliterateOpts
Parent
ParentKeys
ParentMessage
QueueBaseOptions
QueueEventsListener
QueueEventsOptions
QueueListener
QueueOptions
RateLimiterOptions
RawCommand
RepeatBaseOptions
RepeatOptions
SandboxedJob
ScriptMetadata
WorkerListener
WorkerOptions
BackoffStrategy
BulkJobOptions
ClusterOptions
ConnectionOptions
EntryId
EntryRaw
FinishedPropValAttribute
FinishedStatus
FlowChildJob
FlowJob
FlowQueuesOpts
JobData
JobJsonSandbox
JobsOptions
JobState
JobType
KeysMap
MinimalQueue
ParentOpts
Processor
RedisClient
RedisJobOptions
RedisOptions
RepeatableJob
RepeatStrategy
SandboxedJobProcessor
StreamName
StreamReadRaw
clientCommandMessageReg
DELAY_TIME_1
DELAY_TIME_5
errorObject
PRIORITY_LIMIT
QUEUE_EVENT_SUFFIX
RATE_LIMIT_ERROR
scriptLoader
WORKER_SUFFIX
array2obj
asyncSend
childSend
decreaseMaxListeners
delay
errorToJSON
getNextMillis
getParentKey
increaseMaxListeners
isEmpty
isNotConnectionError
isRedisCluster
isRedisInstance
isRedisVersionLowerThan
lengthInUtf8Bytes
parseObjectValues
raw2NextJobData
removeAllQueueData
tryCatch
v5
ChildCommand
ClientType
ErrorCode
MetricsTime
ParentCommand
SpanKind
TelemetryAttributes
AsyncFifoQueue
Backoffs
Child
ChildPool
ChildProcessor
DelayedError
FlowProducer
Job
JobScheduler
Queue
QueueBase
QueueEvents
QueueEventsProducer
QueueGetters
QueueKeys
RateLimitError
RedisConnection
Repeat
Scripts
UnrecoverableError
WaitingChildrenError
Worker
AddChildrenOpts
AddNodeOpts
AdvancedOptions
AdvancedRepeatOptions
Attributes
BackoffOptions
BaseJobOptions
BaseOptions
BuiltInStrategies
ChildMessage
ContextManager
DebounceOptions
DefaultJobOptions
DependenciesOpts
DependencyOpts
FlowJobBase
FlowOpts
FlowProducerListener
GetNextJobOptions
IConnection
IoredisListener
JobJson
JobJsonRaw
JobNode
JobSchedulerJson
JobSchedulerTemplateJson
KeepJobs
Metrics
MetricsOptions
MinimalJob
MoveToDelayedOpts
MoveToWaitingChildrenOpts
NodeOpts
ObliterateOpts
Parent
ParentKeys
ParentMessage
QueueBaseOptions
QueueEventsListener
QueueEventsOptions
QueueListener
QueueOptions
RateLimiterOptions
RawCommand
Receiver
RepeatBaseOptions
RepeatOptions
RetryJobOpts
SandboxedJob
SandboxedOptions
Span
SpanOptions
Telemetry
Tracer
WorkerListener
WorkerOptions
AttributeValue
BackoffStrategy
BulkJobOptions
ClusterOptions
CompressableJobOptions
ConnectionOptions
EntryId
EntryRaw
Exception
ExceptionType
FinishedPropValAttribute
FinishedStatus
FlowChildJob
FlowJob
FlowQueuesOpts
JobData
JobJsonSandbox
JobProgress
JobSchedulerTemplateOptions
JobsOptions
JobState
JobType
KeysMap
MinimalQueue
ParentOpts
Processor
QueueEventsProducerOptions
RedisClient
RedisJobOptions
RedisOptions
RepeatableJob
RepeatableOptions
RepeatStrategy
SandboxedJobProcessor
StreamName
StreamReadRaw
Time
clientCommandMessageReg
DELAY_TIME_1
DELAY_TIME_5
DELAYED_ERROR
errorObject
optsDecodeMap
optsEncodeMap
PRIORITY_LIMIT
QUEUE_EVENT_SUFFIX
RATE_LIMIT_ERROR
UNRECOVERABLE_ERROR
WAITING_CHILDREN_ERROR
array2obj
asyncSend
childSend
decreaseMaxListeners
defaultRepeatStrategy
delay
errorToJSON
getNextMillis
getParentKey
increaseMaxListeners
invertObject
isEmpty
isNotConnectionError
isRedisCluster
isRedisInstance
isRedisVersionLowerThan
lengthInUtf8Bytes
objectToFlatArray
parseObjectValues
raw2NextJobData
removeAllQueueData
removeUndefinedFields
toString
trace
tryCatch
M
M
N
E
P
V
F
C
I
C
P
M
F
P
C
P
T
T
A
A
A
T
R