import { Subject } from 'rxjs';
import { LoggerService } from '../logger/logger.service';
export declare class RabbitService {
    private readonly rabbitConnection;
    private readonly rabbitConfig;
    private loggerService;
    private subscriptions;
    private publisherChannel;
    private status;
    constructor(rabbitConnection: any, rabbitConfig: any, loggerService: LoggerService);
    private setup;
    private initStatus;
    private timeout;
    private connect;
    private initConsumers;
    private initPublishers;
    private createConsumer;
    private getOrCreateSubscription;
    getSubscription(queue: string): Subject<any>;
    publishMessage(routerKey: string, message: any): void;
    isConnected(): any;
}