import { MetricsService } from "./metrics/MetricsService";
import { CustomLogger } from "./CustomLogger";
declare type handlerMessage = (msg: any) => Promise<void>;
export interface ConsumerExchange {
    exchange: string;
    queue?: string;
    handler: handlerMessage;
    onReconnection?: () => Promise<void>;
}
export declare class BrokerMessageService {
    private logger;
    private metrics;
    private connection;
    private channel;
    private consumers;
    isHealth: boolean;
    constructor(logger: CustomLogger, metrics: MetricsService);
    private get ready();
    sendExchangeMessage: <T extends object>(exchange: string, message: T) => Promise<void>;
    addConsumerExchange: (consumer: ConsumerExchange) => Promise<void>;
    private registerConsumerExchange;
    private startAndKeepConnected;
    private createChannel;
}
export {};