import { Exchange, Queue } from 'amqp-ts';
import { AdditionalResourcesConfig, ConsumerConfig, ConsumerCallback, ExchangeOptions, Resources, DeadLetterOptions } from '../types';
/**
 * The main Consumer object, primarily used for registering and activating the
 * consumer. Note that a connection opens before the consumer starts and is
 * never closed unless explicitly interrupted.
 */
declare class RabbitConsumer {
    private callback;
    private config;
    private connection;
    constructor(config: ConsumerConfig, callback: ConsumerCallback);
    connect(): void;
    declareExchange(exchange: string, exchangeOptions: ExchangeOptions): Exchange;
    declareQueue(queue: string, queueOptions: Queue.DeclarationOptions, deadLetterOptions?: DeadLetterOptions): Queue;
    declareResources(config: ConsumerConfig | AdditionalResourcesConfig): Resources;
    declareAdditionalResources(additionalResources: AdditionalResourcesConfig): void;
    run(): void;
}
export default RabbitConsumer;