import IBroadcastChannel from "../modules/IBroadcastChannel";
import { CommandMessage, ICommandProcesser } from "../commandFactory";
import Tranel from "../index";
export declare class Message {
    cmds: CommandMessage[];
    $$messageID: number;
    constructor(cmds: CommandMessage[]);
}
/**
 * 消息的分发器
 *
 * @export
 * @class MessageDispatcher
 */
export default class MessageDispatcher {
    tranel: Tranel;
    queueMap: Map<string, CommandMessage[]>;
    isFlushPending: boolean;
    channel: IBroadcastChannel;
    constructor(tranel: Tranel);
    /**
     * 添加操作的消息列表
     *
     * @param {ICommandProcesser} cmd
     * @param {string} [origin] 消息来源， 当为一对多的通信机制时(比如socket的c/s) client origin为空, server应有值
     * @memberof MessageDispatcher
     */
    addToQueue(cmd: ICommandProcesser, origin?: string): void;
    private processMessage;
    private flush;
    private initQueueMap;
}