import { ClientEventEmitter, ClientEvents, JobId, JobQueue, WorkerEventEmitter, WorkerEvents, Job, JobWorker, BasePayload } from "./JobQueue.js";
import { Redis } from "ioredis";
export declare class RedisJobQueue<Payload extends BasePayload = BasePayload, Response = undefined, Client extends ClientEvents<Response> = ClientEvents<Response>, Worker extends WorkerEvents = WorkerEvents> implements JobQueue<Payload, Response, Client, Worker> {
    private readonly redis;
    private readonly id;
    private readonly queueId;
    constructor(redis: Redis, id?: string);
    close(): Promise<void>;
    notify(jobId: string, eventName: keyof Worker, ...params: Parameters<Worker[typeof eventName]>): Promise<void>;
    private mkWorkerStreamId;
    private mkClientStreamId;
    private readStream;
    monitor(jobId: JobId): Promise<ClientEventEmitter<Response, Client>>;
    register(handler: (job: Job<Payload>, context: ClientEventEmitter<Response, Client>, workerEvents: WorkerEventEmitter<Worker>) => void): Promise<JobWorker>;
    private sendClientMessage;
    private sendWorkerMessage;
    private mkWorkerEventEmitter;
    submit(job: Job<Payload>, preHook?: (emitter: ClientEventEmitter<Response, Client>, id: JobId) => Promise<void>): Promise<JobId>;
    cancel(jobId: JobId): void;
    private setupWorkerStream;
    private setupClientStream;
    private setupStream;
}
//# sourceMappingURL=RedisJobQueue.d.ts.map