import { EventBase } from "./event-base";
import { EventBus } from "./event-bus";
import { EventProcessorOptions } from "./types";
export declare class EventProcessor<PayloadType = unknown, HeadersType = Record<string, unknown>, EventIdType = string> {
    private readonly eventBus;
    private readonly options;
    private isShuttingDown;
    private processingQueue;
    private activeHandlers;
    private eventHandlers;
    private isStarted;
    constructor(eventBus: EventBus<PayloadType, HeadersType, EventIdType>, options: EventProcessorOptions<PayloadType, HeadersType>);
    addHandler(event: EventIdType, handler: (event: EventBase<PayloadType, HeadersType>) => Promise<void>): Promise<void>;
    start(): Promise<void>;
    private subscribeToEvent;
    private processNext;
    private handleError;
    private calculateRetryDelay;
    removeHandler(event: EventIdType): Promise<void>;
    getRegisteredEvents(): EventIdType[];
    hasHandler(event: EventIdType): boolean;
    reset(): Promise<void>;
    restart(): Promise<void>;
    shutdown(): Promise<void>;
    private waitForActiveHandlers;
}