import { Redis } from "ioredis";
import { Closable } from "../Closable";
import { Job } from "../Job";
export declare type SubscriptionOptions = {
    queue?: string;
    id?: string;
};
export declare type OnActivity<ScheduleType extends string> = (event: OnActivityEvent<ScheduleType>) => Promise<void> | void;
export declare type OnActivityEvent<ScheduleType extends string> = ScheduledEvent<ScheduleType> | DeletedEvent | RequestedEvent | InvokedEvent | RescheduledEvent | AcknowledgedEvent;
interface ScheduledEvent<ScheduleType extends string> {
    type: "scheduled";
    job: Job<ScheduleType>;
}
interface InvokedEvent {
    type: "invoked";
    id: string;
    queue: string;
}
interface RescheduledEvent {
    type: "rescheduled";
    id: string;
    queue: string;
    runAt: Date;
}
interface DeletedEvent {
    type: "deleted";
    id: string;
    queue: string;
}
interface RequestedEvent {
    type: "requested";
    id: string;
    queue: string;
}
interface AcknowledgedEvent {
    type: "acknowledged";
    id: string;
    queue: string;
}
export declare class Activity<ScheduleType extends string> implements Closable {
    private readonly redis;
    private readonly onEvent;
    private readonly pattern;
    constructor(redis: Redis, onEvent: OnActivity<ScheduleType>, options?: SubscriptionOptions);
    private matchesPattern;
    private handleMessage;
    close(): Promise<void>;
}
export {};
//# sourceMappingURL=activity.d.ts.map