import type { KythiaContainer } from '../types';
export interface QueueProcessorDefinition {
    queueName: string;
    processorPath: string;
    concurrency?: number;
}
export interface KythiaJob {
    id?: string | number;
    waitUntilFinished: (events: unknown) => Promise<unknown>;
    [key: string]: unknown;
}
export declare class QueueManager {
    private container;
    private redisUrl;
    private queues;
    private sharedRedisConnection;
    isRedisLimitReached: boolean;
    constructor(container: KythiaContainer);
    init(): void;
    private _initQueue;
    dispatch(queueName: string, jobName: string, data: object): Promise<KythiaJob>;
    waitFor(job: KythiaJob, queueName: string): Promise<unknown>;
    shutdown(): Promise<void>;
}
export default QueueManager;
//# sourceMappingURL=QueueManager.d.ts.map