import { BulkJobOptions, ConnectionOptions as RedisConnectionOptions, Job, JobsOptions, Processor, Queue, QueueBaseOptions, QueueOptions, Worker, WorkerOptions } from 'bullmq';
import { IEventJobData, IJobData, JobTopicNameEnum } from '@novu/shared';
import { WorkflowInMemoryProviderService } from '../in-memory-provider';
type BullMqJobData = undefined | IJobData | IEventJobData;
export { Job, JobsOptions, Processor, Queue, QueueBaseOptions, QueueOptions, RedisConnectionOptions as BullMqConnectionOptions, Worker, WorkerOptions, BulkJobOptions, };
export declare class BullMqService {
    private workflowInMemoryProviderService;
    private _queue;
    private _worker;
    static readonly pro: boolean;
    constructor(workflowInMemoryProviderService: WorkflowInMemoryProviderService);
    get worker(): Worker;
    get queue(): Queue;
    get queuePrefix(): string;
    get workerPrefix(): string;
    static haveProInstalled(): boolean;
    private runningWithProQueue;
    private generatePrefix;
    createQueue(topic: JobTopicNameEnum, queueOptions: QueueOptions): Queue<any, any, string>;
    createWorker(topic: JobTopicNameEnum, processor?: string | Processor<any, unknown | void, string>, workerOptions?: WorkerOptions): Worker<any, any, string>;
    add(name: string, data: BullMqJobData, options?: JobsOptions, groupId?: string): void;
    addBulk(data: {
        name: string;
        data: BullMqJobData;
        options?: BulkJobOptions;
        groupId?: string;
    }[]): Promise<void>;
    gracefulShutdown(): Promise<void>;
    getStatus(): Promise<{
        queueIsPaused: boolean | undefined;
        queueName: string | undefined;
        workerIsPaused: boolean | undefined;
        workerIsRunning: boolean | undefined;
        workerName: string | undefined;
    }>;
    isClientReady(): boolean;
    isQueuePaused(): Promise<boolean>;
    isWorkerPaused(): Promise<boolean>;
    isWorkerRunning(): Promise<boolean>;
    pauseWorker(): Promise<void>;
    resumeWorker(): Promise<void>;
}
//# sourceMappingURL=bull-mq.service.d.ts.map