</>
typescriptintermediate

Bull Queue Job Producer & Consumer

Create a job queue with Bull for background processing with retries and concurrency control.

typescript
import Queue from 'bull';

interface EmailJob {
  to: string;
  subject: string;
  body: string;
}

const emailQueue = new Queue<EmailJob>('email', {
  redis: { host: '127.0.0.1', port: 6379 },
  defaultJobOptions: {
    attempts: 3,
    backoff: { type: 'exponential', delay: 2000 },
    removeOnComplete: 100,
  },
});

// Producer
export async function enqueueEmail(data: EmailJob) {
  return emailQueue.add(data, { priority: 1 });
}

// Consumer
emailQueue.process(5, async (job) => {
  console.log(`Sending email to ${job.data.to}`);
  // await sendEmail(job.data);
  return { sent: true };
});

Use Cases

  • Email sending queue
  • Image processing pipeline

Tags

#queue#bull#background-jobs#redis

Related Snippets

Similar patterns you can reuse in the same workflow.

typescriptadvanced

Redis Cache Get/Set Helper

Type-safe Redis cache wrapper with automatic JSON serialization, TTL support, and cache-aside pattern.

#redis#cache
typescriptbeginner

Node.js Cron Job Scheduler

Schedule recurring tasks with node-cron using crontab syntax and timezone support.

#cron#scheduler
bashbeginner

Redis Docker Setup with Persistence

Docker Compose for Redis with persistence, password auth, memory limits, and a health check.

#redis#docker
typescriptintermediate

JWT Verify Middleware

Express middleware that verifies JWT tokens from the Authorization header and attaches the decoded payload to the request.

#jwt#express