Backend Boilerplates typescript Advanced

Bull Queue Job Processor

Process background jobs with BullMQ: add jobs, define worker, handle retries.

typescript

import { Queue, Worker, QueueEvents } from "bullmq";

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

// Add job
await emailQueue.add("welcome", { to: "user@example.com", name: "Alice" }, {
  attempts: 3,
  backoff: { type: "exponential", delay: 5000 },
});

// Worker
const worker = new Worker("emails", async (job) => {
  console.log("Sending email to", job.data.to);
  await sendEmail(job.data);
}, { connection: { host: "localhost", port: 6379 } });

worker.on("failed", (job, err) => console.error(job?.id, err.message));