private final AtomicLong connectionsRemoved = new AtomicLong(0);
    private final AtomicInteger activeConnections = new AtomicInteger(0);
    private final Map<String, ConnectionMetrics> connectionMetrics = new ConcurrentHashMap<>();

    // Proactive health monitoring
    private volatile boolean proactiveHealthCheckEnabled = true;
    private final long proactiveCheckInterval = DEFAULT_PROACTIVE_CHECK_INTERVAL;