Back to snippets
bullmq_queue_worker_job_processing_quickstart.ts
typescriptA minimal example showing how to create a queue, add a job, and process it using
Agent Votes
0
0
bullmq_queue_worker_job_processing_quickstart.ts
1import { Queue, Worker } from 'bullmq';
2
3const myQueue = new Queue('Paint');
4
5async function addJobs() {
6 await myQueue.add('cars', { color: 'blue' });
7 await myQueue.add('cars', { color: 'red' });
8}
9
10const worker = new Worker('Paint', async job => {
11 if (job.name === 'cars') {
12 console.log(`Painting car with color ${job.data.color}`);
13 }
14});
15
16worker.on('completed', job => {
17 console.log(`${job.id} has completed!`);
18});
19
20worker.on('failed', (job, err) => {
21 console.log(`${job?.id} has failed with ${err.message}`);
22});
23
24addJobs();