Question: How can you implement a delay in BullMQ job queues?

Answer

In BullMQ, you can implement a delay in job queues using the delay option when adding jobs. The delay option allows you to specify a time duration (in milliseconds) that BullMQ should wait before processing the job.

Here's an example:

const Queue = require('bullmq').Queue; const queue = new Queue('my-queue'); async function addJob() { await queue.add( 'my-job', { foo: 'bar' }, { delay: 5000 } // Delay job by 5 seconds ); } addJob() .then(() => console.log('Job added')) .catch(err => console.error(err));

In this example, we're adding a job named 'my-job' with data { foo: 'bar' } to the queue called 'my-queue'. The job will not be available for processing until 5 seconds (5000 milliseconds) have passed.

Note, the actual delay may be longer than the specified delay time due to how the event loop scheduling works in Node.js. Also remember, the delay is relative to when queue.add() is called, not when the job reaches the front of the queue.

Was this content helpful?

White Paper

Free System Design on AWS E-Book

Download this early release of O'Reilly's latest cloud infrastructure e-book: System Design on AWS.

Free System Design on AWS E-Book
Start building today

Dragonfly is fully compatible with the Redis ecosystem and requires no code changes to implement.