import amqp, { Options } from "amqplib";
import amqpManager from "amqp-connection-manager";
import { TBackoffAttemptArray } from "../events/index.js";
export declare const PUBLISHER_CONTENT_TYPE = "application/json";
export declare const PUBLISHER_CONTENT_ENCODING = "utf-8";
export type TAddChannelsFunction = (channel: amqp.Channel) => Promise<void>;
export declare enum ERabbitChannelType {
    CONSUMER = "consumer",
    PUBLISHER = "publisher"
}
export type TRabbitMQConfig = {
    concurrency: number;
    backOff: TBackoffAttemptArray;
    exchangeOptions: Options.AssertExchange;
    queueOptions: Options.AssertQueue;
    publishOptions: Options.Publish;
    consumeOptions: Options.Consume;
    maxVersionRetry: number;
};
export type TRabbitManagedConsumerChannels = {
    consumer: amqpManager.ChannelWrapper[];
};
export type TRabbitManagedPublisherChannels = {
    publisher: amqpManager.ChannelWrapper[];
};
//# sourceMappingURL=interfaces.d.ts.map