BullMQ
Search…
Guide
Patterns
BullMQ Pro
Bull 3.x Migration
Sandboxed processors
It is also possible to define workers to run on a separate process, we call this processors for sandboxed, because they run isolated from the rest of the code.
Since these workers run the processor in a different process, they will not result in stalled jobs as easily as standard workers, although it is not completely impossible if the CPUs in the system are so overload that there is no practical time for the worker to perform its bookkeeping to avoid stalling.
In order to use a sandboxed processor just define the processor in a separate file:
1
import { SandboxedJob } from 'bullmq';
2
3
module.exports = async (job: SandboxedJob) => {
4
// Do something with job
5
};
Copied!
and refer to it in the worker constructor:
1
import { Worker } from 'bullmq'
2
3
const processorFile = path.join(__dirname, 'my_procesor.js');
4
worker = new Worker(queueName, processorFile);
Copied!
Last modified 8mo ago
Copy link