This symbol shall be used to install a listener for only monitoring 'error'
events. Listeners installed using this symbol are called before the regular
'error'
listeners are called.
Installing a listener using this symbol does not change the behavior once an
'error'
event is emitted, therefore the process will still crash if no
regular 'error'
listener is installed.
queue.workingOn
with the worker names as keys.func
and argument collection within a given queue.delByFunction
queue to look in
function name to delete any jobs with
optional place to start looking in list (default: beginning of list)
optional place to end looking in list (default: end of list)
number of jobs deleted from queue
count
is an integer. You might delete more than one lock by the name.jobsEnqueuedForThisTimestamp
is an array, matching the style of the response of queue.queued
jobs
to be worked by a worker)queueName
queue, and that queue will be worked down by available workers assigned to that queuequeueName
, it is likely that this job will not be excecuted at exactly the time specified, but shortly thereafter.queue.enqueue
queueName
, it is likely that this job will not be excecuted at exactly the delay specified, but shortly thereafter.queue.enqueue
failedJobs
is an array listing the data of the failed jobs. Each element looks like:{"worker": "host:pid", "queue": "test_queue", "payload": {"class":"slowJob", "queue":"test_queue", "args":[null]}, "exception": "TypeError", "error": "MyImport is not a function", "backtrace": [' at Worker.perform (/path/to/worker:111:24)', ' at <anonymous>'], "failed_at": "Fri Dec 12 2014 14:01:16 GMT-0800 (PST)"}\
await queue.failed(0, -1)
failedCount
is the number of jobs in the failed queueReturn the currently elected leader
The redis key which holds the currently elected leader
locks
is a hash by type and timestampLook though the failed jobs to find those which were failed as a result of forceCleanWorker and re-enqueue them. This is potentially very slow if you have a lot of failed jobs
timestampsForJob
is an array of integerstimestamps
is an array of integers for all timestamps which have at least one job scheduled in the future{ 'host:pid': 'queue1, queue2', 'host:pid': 'queue1, queue2' }
{"run_at":"Fri Dec 12 2014 14:01:16 GMT-0800 (PST)","queue":"test_queue","payload":{"class":"slowJob","queue":"test_queue","args":[null]},"worker":"workerA"}
Generated using TypeDoc
Sets or gets the default captureRejection value for all emitters.