import { DiscoveryService } from '@nestjs/core';
import { IMessageBus } from '../bus/i-message-bus';
import { ChannelRegistry } from '../channel/channel.registry';
import { MessagingLogger } from '../logger/messaging-logger';
import { ExceptionListenerHandler } from '../exception-listener/exception-listener-handler';
import { MessagingLifecycleHookHandler } from '../lifecycle-hook/messaging-lifecycle-hook-handler';
export declare class DistributedConsumer {
    private readonly messageBus;
    private readonly channelRegistry;
    private readonly exceptionListenerHandler;
    private readonly logger;
    private readonly discoveryService;
    private readonly messagingLifecycleHookHandler;
    constructor(messageBus: IMessageBus, channelRegistry: ChannelRegistry, exceptionListenerHandler: ExceptionListenerHandler, logger: MessagingLogger, discoveryService: DiscoveryService, messagingLifecycleHookHandler: MessagingLifecycleHookHandler);
    run(): Promise<void>;
}