BullMQ vs Inngest

import { Queue, Worker } from 'bullmq';
import { Redis } from 'ioredis';

const connection = new Redis({ maxRetriesPerRequest: null });

// Producer: add jobs to the queue
const emailQueue = new Queue('emails', { connection });
await emailQueue.add('welcome', { to: 'alice@example.com', name: 'Alice' });

// Consumer: process jobs
const worker = new Worker('emails', async (job) => {
  console.log(`Sending email to ${job.data.to}`);
  await sendEmail(job.data);
}, { connection });

import { Inngest } from 'inngest';

const inngest = new Inngest({ id: 'my-app' });

// Define a background function
export const sendWelcomeEmail = inngest.createFunction(
  { id: 'send-welcome-email' },
  { event: 'user/signup' },
  async ({ event, step }) => {
    // Step 1: send email
    await step.run('send-email', () =>
      sendEmail(event.data.email, 'Welcome!')
    );

    // Step 2: wait 3 days, then send follow-up
    await step.sleep('wait-3-days', '3 days');
    await step.run('send-followup', () =>
      sendEmail(event.data.email, 'How are you finding things?')
    );
  }
);