import { JobTopicNameEnum } from '@novu/shared';
import { BullMqService, JobsOptions, BulkJobOptions, Queue, QueueOptions } from '../bull-mq';
export declare class QueueBaseService {
    readonly topic: JobTopicNameEnum;
    private bullMqService;
    private instance;
    readonly DEFAULT_ATTEMPTS = 3;
    queue: Queue;
    constructor(topic: JobTopicNameEnum, bullMqService: BullMqService);
    createQueue(overrideOptions?: QueueOptions): void;
    private getQueueOptions;
    isReady(): boolean;
    isPaused(): Promise<boolean>;
    getStatus(): Promise<{
        queueIsPaused: boolean;
        queueName: string;
        workerIsPaused: boolean;
        workerIsRunning: boolean;
        workerName: string;
    }>;
    getGroupsJobsCount(): Promise<any>;
    getWaitingCount(): Promise<number>;
    getDelayedCount(): Promise<number>;
    getActiveCount(): Promise<number>;
    gracefulShutdown(): Promise<void>;
    add(params: IJobParams): Promise<void>;
    addBulk(data: IBulkJobParams[]): Promise<void>;
    onModuleDestroy(): Promise<void>;
}
export interface IJobParams {
    name: string;
    data?: any;
    groupId?: string;
    options?: JobsOptions;
}
export interface IBulkJobParams {
    name: string;
    data: any;
    groupId?: string;
    options?: BulkJobOptions;
}
//# sourceMappingURL=queue-base.service.d.ts.map