import { QueueDispatcher } from "../contracts/queue-dispatcher.contract.mjs"; import { JobBackoff } from "@warlock.js/queue"; //#region ../notifications/src/queue/bullmq-queue.d.ts /** The job name notification deliveries run under. */ declare const NOTIFICATION_JOB_NAME = "warlock.notifications.deliver"; type BullmqQueueOptions = { /** Queue to deliver on. Default: `@warlock.js/queue`'s default queue. */queue?: string; /** Attempts per delivery. Default: `queue.defaultJobOptions.attempts`, else `1`. */ attempts?: number; /** Backoff between attempts. */ backoff?: JobBackoff; }; /** * Create the `QueueDispatcher` for `NotificationConfig.queue` backed by * `@warlock.js/queue`. * * - `SendOptions.delay` is honoured: a number is SECONDS (notifications' * convention), a string is a duration such as `"10m"` (`@warlock.js/queue`'s * convention). * - A channel missing from the worker's notifications config throws — the * delivery is retried per `attempts` / `backoff` like any other failure. */ declare function bullmqQueue(options: BullmqQueueOptions): QueueDispatcher; //#endregion export { BullmqQueueOptions, NOTIFICATION_JOB_NAME, bullmqQueue }; //# sourceMappingURL=bullmq-queue.d.mts.map