import type { BullMQProviderConfig, DeadLetterJob, JobHandler, JobPayload, JobResult, JobStatusInfo, QueueProvider } from "../types";
interface BullMQFailedJobLike {
    id?: string;
    data: JobPayload;
    attemptsMade: number;
    opts: {
        attempts?: number;
    };
    failedReason?: string;
    finishedOn?: number;
}
export declare function toBullMQDeadLetterJob(queue: string, job: BullMQFailedJobLike): DeadLetterJob | undefined;
export declare class BullMQProvider implements QueueProvider {
    readonly name: "bullmq";
    private connection;
    private queues;
    private workers;
    private handlers;
    private prefix;
    private concurrency;
    constructor(config: Omit<BullMQProviderConfig, "provider">);
    private getOrCreateQueue;
    enqueue(job: JobPayload): Promise<JobResult>;
    enqueueBatch(jobs: JobPayload[]): Promise<JobResult[]>;
    registerHandler<T extends Record<string, unknown>>(queue: string, type: string, handler: JobHandler<T>): void;
    private ensureWorker;
    getJobStatus(jobId: string, queue: string): Promise<JobStatusInfo | undefined>;
    getDeadLetteredJobs(queue?: string): Promise<DeadLetterJob[]>;
    close(): Promise<void>;
}
export {};
//# sourceMappingURL=bullmq.d.ts.map