Message Queues in Node.js with RabbitMQ & BullMQ

BullMQ Job Processing

const { Queue, Worker } = require('bullmq');

const emailQueue = new Queue('emails', { connection: { host: 'localhost', port: 6379 } });

// Producer adds job
await emailQueue.add('sendWelcome', { email: 'alex@example.com', name: 'Alex' });

// Consumer worker processes job
const worker = new Worker('emails', async (job) => {
    console.log(`Processing email to ${job.data.email}`);
});