import * as Component from './Component';
import { Command } from './Command';
import { Typer } from 'cqes-type';
export declare type commandHandler = (commmand: Command) => Promise<void>;
export declare class ConcurencyError extends Error {
    retry: boolean;
    constructor(e: Error);
}
export interface Subscription {
    abort: () => Promise<void>;
}
export interface CommandTypes {
    [name: string]: Typer;
}
export interface Transport {
    start: () => Promise<void>;
    listen: (channel: string, handler: commandHandler) => Promise<Subscription>;
    send: (command: Command) => Promise<void>;
    stop: () => Promise<void>;
}
export interface props extends Component.props {
    transport: string;
    channel: string;
    commands: CommandTypes;
}
export declare class CommandBus extends Component.Component {
    protected commands: CommandTypes;
    protected transport: Transport;
    protected channel: string;
    protected category: string;
    constructor(props: props);
    start(): Promise<void>;
    listen(handler: commandHandler): Promise<Subscription>;
    send(id: string, order: string, data: any, meta?: any): Promise<void>;
    sendCommand(command: Command): Promise<void>;
    stop(): Promise<void>;
}