// queues.ts
import { Queue } from 'bullmq';
import { connection } from './redis-conn';

export const summarizationQueue = new Queue('summarize', { connection });
export const emailQueue = new Queue('email', { connection });

// producer.ts
await summarizationQueue.add('summarizeDoc', {
  docId: 'abc123',
});

// summarization.worker.ts
import { Worker } from 'bullmq';
import { summarizationQueue, emailQueue } from './queues';

new Worker('summarize', async job => {
  const summary = await generateSummary(job.data.docId);
  await emailQueue.add('sendEmail', {
    userId: job.data.userId,
    summary,
  });
});