import type { ChannelContract } from "../../contracts";
import type { ChannelOptions, ChannelStats, MessageHandler, PublishOptions, RequestOptions, ResponseHandler, SubscribeOptions, Subscription } from "../../types";
/**
 * RabbitMQ Channel Implementation
 *
 * Wraps a RabbitMQ queue/exchange with a unified API.
 *
 * @template TPayload - The typed payload
 */
export declare class RabbitMQChannel<TPayload = unknown> implements ChannelContract<TPayload> {
    readonly name: string;
    readonly options: ChannelOptions<TPayload>;
    private readonly amqpChannel;
    private readonly subscriptions;
    private asserted;
    /**
     * Create a new RabbitMQ channel
     */
    constructor(name: string, amqpChannel: any, options?: ChannelOptions<TPayload>);
    /**
     * Assert the queue exists
     */
    assert(): Promise<void>;
    /**
     * Publish a message
     */
    publish(payload: TPayload, options?: PublishOptions): Promise<void>;
    /**
     * Publish multiple messages
     */
    publishBatch(messages: TPayload[], options?: PublishOptions): Promise<void>;
    /**
     * Subscribe to messages
     *
     * Smart auto-ack behavior (when autoAck is not true):
     * - If handler completes successfully without explicit ack/nack/reject → auto-ack
     * - If handler throws an error → auto-nack (with retry if configured)
     * - If handler explicitly calls ack/nack/reject → respects that call
     */
    subscribe(handler: MessageHandler<TPayload>, options?: SubscribeOptions): Promise<Subscription>;
    /**
     * Unsubscribe by consumer ID
     */
    unsubscribeById(consumerId: string): Promise<void>;
    /**
     * Stop consuming messages on this channel.
     * Cancels all active subscriptions gracefully.
     */
    stopConsuming(): Promise<void>;
    /**
     * Send message to dead-letter queue
     */
    private sendToDeadLetter;
    /**
     * Request-response pattern
     */
    request<TResponse = unknown>(payload: TPayload, options?: RequestOptions): Promise<TResponse>;
    /**
     * Register response handler for RPC
     */
    respond<TResponse = unknown>(handler: ResponseHandler<TPayload, TResponse>): Promise<Subscription>;
    /**
     * Get queue statistics
     */
    stats(): Promise<ChannelStats>;
    /**
     * Purge all messages
     */
    purge(): Promise<number>;
    /**
     * Check if queue exists
     */
    exists(): Promise<boolean>;
    /**
     * Delete the queue
     */
    delete(): Promise<void>;
}
//# sourceMappingURL=rabbitmq-channel.d.ts.map