import { Channel, ChannelModel } from "amqplib";
export declare class RabbitMqClient {
    private readonly connection;
    private readonly mainChannel;
    private connected;
    constructor(connection: ChannelModel, mainChannel: Channel);
    createQueue(queueName: string): Promise<void>;
    bind(exchange: string, routingKey: string, queue: string): Promise<void>;
    publish(exchange: string, routingKey: string, message: string): Promise<void>;
    subscribe(queue: string, consumer: (message: string) => void): Promise<void>;
    closeConnection(): Promise<void>;
    isConnected(): boolean;
}