import { RabbitMQMessage } from './rabbitmq-message.interface';
export interface InboxConsumerOptions {
    defaultSource?: string;
    onError?: (error: Error, message: RabbitMQMessage) => void | Promise<void>;
    autoAck?: boolean;
    logDuplicates?: boolean;
}
export interface InboxSubscribeOptions {
    exchange: string;
    routingKey: string | string[];
    queue?: string;
    queueOptions?: Record<string, unknown>;
    source?: string;
    messageIdExtractor?: (message: RabbitMQMessage) => string;
    eventTypeExtractor?: (message: RabbitMQMessage) => string;
    maxRetries?: number;
    enableRetry?: boolean;
    backoffBaseSeconds?: number;
    maxBackoffSeconds?: number;
}
//# sourceMappingURL=inbox-consumer-options.interface.d.ts.map