eletrotupi / tcc/ api/src/lib/queue/QueueRegistry.ts031a372a6e1f95cfbac1b82e2078da48a3674fb3
751 B | 30 lines Raw
1
import { Queue, QueueOptions } from 'bullmq';
2
3
export type QueueName = 'mail'; // TODO: add image here later on
4
5
const queues = new Map<QueueName, Queue>();
6
7
const defaultOpts: QueueOptions = {
8
  connection: {
9
    host: process.env.VALKEY_HOST,
10
    port: Number(process.env.VALKEY_PORT)
11
  },
12
  defaultJobOptions: {
13
    attempts: 3,
14
    backoff: { type: 'exponential', delay: 2000 },
15
    removeOnComplete: { count: 100 },
16
    removeOnFail: { count: 500 },
17
  },
18
};
19
20
export function getQueue(name: QueueName): Queue {
21
  if (!queues.has(name)) {
22
    queues.set(name, new Queue(name, defaultOpts));
23
  }
24
25
  return queues.get(name)!;
26
}
27
28
export async function closeAllQueues(): Promise<void> {
29
  await Promise.all([...queues.values()].map(q => q.close()));
30
}