bullmq_repeatable_scheduled_job_with_redis_worker.ts

1import { Queue, Worker, Job } from 'bullmq';
2
3// 1. Create a connection configuration
4const connection = {
5  host: 'localhost',
6  port: 6379,
7};
8
9// 2. Initialize the Queue
10const myQueue = new Queue('paint-jobs', { connection });
11
12// 3. Add a scheduled (repeatable) job
13async function addScheduledJob() {
14  await myQueue.add(
15    'every-10-seconds',
16    { color: 'blue' },
17    {
18      repeat: {
19        every: 10000, // 10,000 milliseconds = 10 seconds
20      },
21    }
22  );
23  console.log('Scheduled job added!');
24}
25
26// 4. Initialize a Worker to process the jobs
27const worker = new Worker(
28  'paint-jobs',
29  async (job: Job) => {
30    console.log(`Processing job ${job.id} with data:`, job.data);
31  },
32  { connection }
33);
34
35worker.on('completed', (job) => {
36  console.log(`${job.id} has completed!`);
37});
38
39worker.on('failed', (job, err) => {
40  console.log(`${job?.id} has failed with ${err.message}`);
41});
42
43// Run the script
44addScheduledJob();