import type { Redis } from 'ioredis';
import type { ILoggerModule } from '@omnitron-dev/titan/module/logger';
import type { INotificationTargetResolver, INotificationPersister, INotificationRealtimeSignaler } from './worker.interfaces.js';
export interface NotificationWorkerOptions {
    streamPattern?: string;
    groupName?: string;
    consumerName?: string;
    blockTimeoutMs?: number;
    readCount?: number;
    autoclaimIdleMs?: number;
    autoclaimIntervalMs?: number;
}
export declare class NotificationWorkerService {
    private readonly targetResolver;
    private readonly persister;
    private readonly signaler;
    private readonly loggerService;
    private redis;
    private active;
    private loopPromise;
    private autoclaimTimer;
    private streamKey;
    private groupName;
    private consumerName;
    private blockTimeoutMs;
    private readCount;
    private autoclaimIdleMs;
    private autoclaimIntervalMs;
    constructor(targetResolver: INotificationTargetResolver, persister: INotificationPersister, signaler: INotificationRealtimeSignaler, loggerService: ILoggerModule);
    private get logger();
    start(redis: Redis, options?: NotificationWorkerOptions): Promise<void>;
    stop(): Promise<void>;
    private ensureConsumerGroup;
    private consumeLoop;
    private handleMessage;
    private parseFields;
    private processEvent;
    private runAutoclaim;
    private ack;
}
//# sourceMappingURL=notification-worker.d.ts.map