import { Queue } from '../../types';
import { Base } from '../../utils/celery/base';
import { Message } from '../../utils/celery/message';
declare type Handler = (...args: any[]) => Promise<void>;
export declare class CeleryQueue extends Base implements Queue {
    handlers: Record<string, Handler>;
    activeTasks: Set<Promise<any>>;
    register(name: string, handler: Handler): void;
    start(): Promise<any>;
    pause(): Promise<void>;
    resume(): void;
    isPaused(): boolean;
    private run;
    private processTasks;
    private getConsumer;
    createTaskHandler(): (message: Message) => any;
    whenCurrentJobsFinished(): Promise<any[]>;
    stop(): Promise<void>;
}
export {};