export interface EventPublisher {
    publishRetry<T>(message: T, routingKey: string, maxRetries?: number, logEvent?: boolean): Promise<void>;
    publish<T>(message: T, routingKey: string, logEvent?: boolean): Promise<void>;
    close(): Promise<void>;
    hasActiveConnection(): Promise<boolean>;
}