inceptum/dist/rabbitmq/RabbitmqConfig.d.ts

import { ConsumeOptions } from './RabbitmqClient';
export declare enum RabbitmqBackPressureStrategy {
    ERROR = 0,
    BLOCK = 1,
}
export interface RabbitmqClientConfig {
    protocol?: string;
    hostname: string;
    port: number;
    username: string;
    password: string;
    mgtHttpHost: string;
    mgtHttpPort: number;
    mgtHttpTheme: string;
    maxConnectionAttempts?: number;
    exitOnIrrecoverableReconnect?: boolean;
    healthCheckEnabled?: boolean;
    heartbeat?: number;
}
export declare const DEFAULT_MAX_CONNECTION_ATTEMPTS = 3;
export interface RabbitmqProducerConfig {
    exchangeName: string;
    backPressureStrategy: RabbitmqBackPressureStrategy;
}
export interface RabbitmqConsumerConfig {
    appQueueName: string;
    delayQueueName: string;
    dlqName: string;
    maxRetries: number;
    retryDelayInMinute: number;
    retryDelayFactor: number;
    messageHandler?: string;
    prefetch?: number;
    options?: ConsumeOptions;
}