/// <reference types="node" />
import * as Component from '../Component';
import * as CommandBus from '../CommandBus';
import { Command } from '../Command';
import * as amqp from 'amqplib';
export declare type commandHandler = (command: Command<any>) => Promise<void>;
export declare type ConcurencyError = CommandBus.ConcurencyError;
export interface Listener {
    queue: string;
    handler: commandHandler;
}
export interface props extends Component.props {
    AMQP: Config;
}
export interface Config {
    url?: string;
    channel?: amqp.Options.AssertQueue;
    publish?: amqp.Options.Publish;
    prefetch?: number;
}
export declare class Transport extends Component.Component implements CommandBus.Transport {
    protected config: Config;
    protected amqp: amqp.Connection;
    protected lastConnection: number;
    protected connectFlag: NodeJS.Timer;
    protected listeners: Array<Listener>;
    protected channels: Map<string, amqp.Channel | Array<any>>;
    constructor(props: props);
    start(): Promise<void>;
    protected connect(): Promise<void>;
    listen(queue: string, handler: commandHandler): Promise<CommandBus.Subscription>;
    protected bind(queue: string, handler: commandHandler): Promise<void>;
    protected getChannel(queue: string): Promise<amqp.Channel>;
    send(command: Command<any>): Promise<void>;
    protected reconnect(): Promise<void>;
    protected unbind(queue: string, handler: commandHandler): Promise<void>;
    protected disconnect(): Promise<void>;
    stop(): Promise<void>;
}