Function closeQueuesAndWorkers

server/setUpQueues.js:204–236

(signal)

  let isShuttingDown = false;
  const closeQueuesAndWorkers = async (signal) => {
    if (isShuttingDown) {
      return;
    }

    isShuttingDown = true;
    console.log(`${signal} received. Closing BullMQ workers and queues...`); // eslint-disable-line

    const workerResults = await Promise.allSettled(workersToClose.map((worker) => worker.close()));
    workerResults
      .filter((result) => result.status === "rejected")
      .forEach((result) => {
        console.error(`Failed to close worker: ${result.reason?.message || result.reason}`); // eslint-disable-line
      });

    const queueResults = await Promise.allSettled(queuesToClose.map((queue) => queue.close()));
    queueResults
      .filter((result) => result.status === "rejected")
      .forEach((result) => {
        console.error(`Failed to close queue: ${result.reason?.message || result.reason}`); // eslint-disable-line
      });

    const queueEventResults = await Promise.allSettled(
      queueEventsToClose.map((queueEvents) => queueEvents.close())
    );
    queueEventResults
      .filter((result) => result.status === "rejected")
      .forEach((result) => {
        console.error(`Failed to close queue events: ${result.reason?.message || result.reason}`); // eslint-disable-line
      });

    process.exit(0);
  };

  ["SIGINT", "SIGTERM", "SIGUSR2"].forEach((signal) => {
    process.on(signal, () => {