import { ClientProxy, ReadPacket, WritePacket } from "@nestjs/microservices";
import { LoggerService } from "../logger/logger.service";
export interface RabbitMQClientOptions {
    exchangeName: string;
    queueName: string;
    persistent: boolean;
    ttl?: number;
    isRPCSupported?: boolean;
    rpcTimeoutSecs?: number;
    logger: LoggerService;
}
export declare const MESSAGE_BROKER_URI: string;
export declare class RabbitMQClientProxy extends ClientProxy {
    private readonly _options;
    private _channel;
    private _replyToQueue;
    private _replyToExchange;
    private _responseEmitter;
    private _logger;
    constructor(_options: RabbitMQClientOptions);
    connect(): Promise<void>;
    close(): Promise<void>;
    dispatchEvent(packet: ReadPacket<any>): Promise<any>;
    publish(packet: ReadPacket<any>, callback: (packet: WritePacket<any>) => void): () => void;
}