import { ActionData, ActionResponse, CommandManager, EventData } from './actions';
import * as RX from 'rx';
export declare class MessageBus {
    private manager;
    private commandBus;
    private eventBus;
    private _events;
    getEventsQueue(domain: string): RX.Observable<EventData>;
    constructor(manager: CommandManager, hasAsyncActions: boolean);
    private consumeEventAsync(event);
    pushTask(command: ActionData): void;
    sendEvent(response: ActionResponse<any>): void;
}