import { Channel } from 'amqplib';
import { QueueOptions } from '../types';
export declare class Consumer {
    private getChannel;
    private messageProcessor;
    constructor(getChannel: () => Channel);
    registerConsumer(options: QueueOptions): Promise<void>;
}
//# sourceMappingURL=consumer.d.ts.map