import { Channel, ConsumeMessage } from 'amqplib';
import { QueueOptions } from '../types';
export declare class MessageProcessor {
    private getChannel;
    private retryHandler;
    constructor(getChannel: () => Channel);
    processMessage(msg: ConsumeMessage, options: QueueOptions): Promise<void>;
    private handleProcessingError;
    private createProcessedMessage;
}
//# sourceMappingURL=message-processor.d.ts.map