Message Queues

1
2
3
4
5
6
7
8
9

const Queue = require('bull');

const emailQueue = new Queue('emails');

emailQueue.add({ to: 'user@test.com', subject: 'Welcome' });

emailQueue.process(async (job) => {
    await sendEmail(job.data);
});

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

const Queue = require("bull");

const emailQueue = new Queue("emails", {
    redis: { host: "127.0.0.1", port: 6379 }
});

// Add job
emailQueue.add({
    to: "user@example.com",
    subject: "Welcome!",
    body: "Thanks for signing up."
});

// Process jobs
emailQueue.process(async (job) => {
    console.log("Sending email to:", job.data.to);
    // await sendEmail(job.data);
    return { sent: true };
});

emailQueue.on("completed", (job) => {
    console.log("Job completed:", job.id);
});