import { type AMQPChannel } from "@cloudamqp/amqp-client";
import type { AMQPConfig } from "./types.js";
/**
 * Manages AMQP connection lifecycle with reconnection support
 */
export declare class AMQPConnection {
    private client;
    private publishChannel;
    private consumeChannel;
    private config;
    private logger;
    private reconnectAttempts;
    private isReconnecting;
    private reconnectPromise;
    constructor(config: AMQPConfig);
    /**
     * Establish connection to AMQP broker and setup channels
     */
    connect(): Promise<void>;
    /**
     * Handle connection loss and attempt reconnection
     */
    private handleDisconnect;
    /**
     * Perform the actual reconnection logic
     */
    private performReconnection;
    /**
     * Get publish channel
     */
    getPublishChannel(): Promise<AMQPChannel>;
    /**
     * Get consume channel
     */
    getConsumeChannel(): Promise<AMQPChannel>;
    /**
     * Get exchange name from config
     */
    getExchange(): string;
    /**
     * Get full config
     */
    getConfig(): Required<AMQPConfig>;
    /**
     * Close connection gracefully
     */
    close(): Promise<void>;
}
//# sourceMappingURL=AMQPConnection.d.ts.map