Method close

apps/api/src/queues/queue-manager.ts:209–238

()

  }

  async close(): Promise<void> {
    logger.info("Closing queues + workers", {
      event: "queues.shutdown.started",
    });

    const tasks: Promise<void>[] = [
      this.accountMaintenanceWorker.close(),
      this.accountMaintenanceQueue.close(),
      this.emailDeliveryWorker.close(),
      this.emailDeliveryQueue.close(),
      this.notificationDispatchWorker.close(),
      this.notificationDispatchQueue.close(),
      this.notificationMaintenanceWorker.close(),
      this.notificationMaintenanceQueue.close(),
    ];

    if (this.webPushDeliveryWorker !== null) {
      tasks.push(this.webPushDeliveryWorker.close());
    }

    if (this.webPushDeliveryQueue !== null) {
      tasks.push(this.webPushDeliveryQueue.close());
    }

    await Promise.all(tasks);

    logger.info("Queues + workers closed", {
      event: "queues.shutdown.completed",
    });
  }
}