import { IActionBusAdapter, IEventBusAdapter } from '../bus/busAdapter';
import { EventData } from "./messageBus";
import { RequestData } from "../pipeline/common";
export declare class LocalAdapter implements IActionBusAdapter, IEventBusAdapter {
    private eventQueue;
    private taskQueue;
    open(): Promise<void>;
    stopReception(): void;
    sendEvent(domain: string, event: EventData): void;
    consumeEvents(domain: string, handler: (event: EventData) => void, queueName?: string): void;
    publishTask(domain: string, serviceId: string, command: RequestData): void;
    consumeTask(domain: string, serviceId: string, handler: (event: RequestData) => void): void;
}