import { EventEmitter } from 'events'; export declare class IdempotencyStore extends EventEmitter { private processedMessages; private readonly TTL_MS; private cleanupInterval?; constructor(); private startCleanupInterval; dispose(): void; markAsProcessed(messageId: string, result?: any): Promise; hasBeenProcessed(messageId: string): Promise<{ processed: boolean; result?: any; }>; private cleanup; }