import BaseQueue, { Queue as BullQueue, QueueOptions, JobOptions } from 'bull';
import { Application, Router } from 'egg';
declare class QueueBase<T, A extends Application = Application> {
    protected queue: BullQueue<T>;
    protected logger: any;
    protected app: A;
    protected name: string;
    constructor(app: A, queueOptions?: QueueOptions, name?: string, listenEvents?: boolean);
    private initQueue;
}
export declare abstract class Queue<T, R = any, A extends Application = Application> extends QueueBase<T, A> {
    startProcess(): void;
    protected abstract process(params: T): Promise<R>;
    run(ctx: any, params: T, jobOptions?: JobOptions): Promise<void>;
    send(ctx: any, params: T, jobOptions?: JobOptions): Promise<void>;
}
export declare class Sender<T, A extends Application = Application> extends Queue<T, any, A> {
    constructor(app: A, queueOptions?: QueueOptions, name?: string);
    startProcess(): void;
    process(params: T): Promise<any>;
}
export declare class QueueAdmin {
    static getStats(qName: string): Promise<BaseQueue.JobCounts>;
    static getAllStats(): Promise<{
        queueName: string;
        stats: BaseQueue.JobCounts;
    }[]>;
    static pause(qName: string): Promise<void>;
    static resume(qName: string): Promise<void>;
    static getFailed(qName: string, start?: number, end?: number): Promise<BaseQueue.Job<any>[]>;
}
export declare const registryAdminRouter: (rp: Router, pathPrefix: string) => void;
export {};