import { NotificationManager } from '../rotif/rotif.js';
import type { DLQCleanupConfig } from '../rotif/dlq-manager.js';
import type { MessagingTransport, NotificationMessage, TransportPublishOptions, TransportPublishResult, TransportSubscribeOptions, NotificationHandler, NotificationSubscription, TransportHealth, DLQQueryOptions, TransportMiddleware } from './transport.interface.js';
import { type ILogger } from '@omnitron-dev/titan/types';
export declare class RotifTransport implements MessagingTransport {
    private readonly manager;
    readonly id: string;
    readonly type = "rotif";
    private middlewares;
    private readonly logger;
    constructor(manager: NotificationManager, logger?: ILogger);
    publish(channel: string, message: NotificationMessage, options?: TransportPublishOptions): Promise<TransportPublishResult>;
    subscribe(pattern: string, handler: NotificationHandler, options?: TransportSubscribeOptions): Promise<NotificationSubscription>;
    healthCheck(): Promise<TransportHealth>;
    shutdown(): Promise<void>;
    waitUntilReady(): Promise<void>;
    destroy(): Promise<void>;
    subscribeToDLQ(handler: NotificationHandler): Promise<void>;
    requeueFromDLQ(count?: number): Promise<number>;
    getDLQStats(): Promise<import("../rotif/dlq-manager.js").DLQStats>;
    getDLQMessages(options?: DLQQueryOptions): Promise<import("../rotif/dlq-manager.js").DLQMessageInfo[]>;
    cleanupDLQ(): Promise<number>;
    clearDLQ(): Promise<void>;
    updateDLQConfig(config: Partial<DLQCleanupConfig>): void;
    use(middleware: TransportMiddleware): void;
    getManager(): NotificationManager;
}
export declare function createRotifTransport(manager: NotificationManager): RotifTransport;
//# sourceMappingURL=rotif.transport.d.ts.map