import type { Message } from '../core/types';
/**
 * Per-session message queue with debounce.
 *
 * - Messages from the same session are processed sequentially
 * - Fast consecutive messages (within debounceMs) are batched together
 * - Different sessions process in parallel
 */
export declare class MessageQueue {
    private handler;
    private debounceMs;
    private queues;
    private processing;
    private debounceTimers;
    constructor(handler: (sessionId: string, messages: Message[]) => Promise<void>, debounceMs?: number);
    enqueue(sessionId: string, message: Message): void;
    private processQueue;
}
//# sourceMappingURL=message-queue.d.ts.map