/** * @rlanz/bull-queue * * @license MIT * @copyright Romain Lanz */ /// /// /// /// /// /// /// /// /// /// import type { JobsOptions } from 'bullmq'; import { Queue } from 'bullmq'; import type { LoggerContract } from '@ioc:Adonis/Core/Logger'; import type { ApplicationContract } from '@ioc:Adonis/Core/Application'; import type { DataForJob, JobsList, QueueConfig } from '@ioc:Rlanz/Queue'; export declare class BullManager { private options; private logger; private app; private queues; private maybeAddQueue; constructor(options: QueueConfig, logger: LoggerContract, app: ApplicationContract); getQueue(queueName?: 'default' | string): Queue; dispatch(job: K, payload: DataForJob, options?: JobsOptions & { queueName?: string; }): Promise>; process({ queueName }: { queueName?: string; }): this; clear(queueName: K): Promise; list(): Map>; get(queueName: K): void | Queue; closeAll(): Promise; }