*/
    private CompletableFuture<HandleInfo> attemptReconnect(HandleInfo info, int attempt, Exception originalCause) {
        if (attempt >= maxRetries) {
            handleManager.completeReconnect(info.getPath(), false);
            return CompletableFuture.failedFuture(new IOException(
                    "Failed to reconnect after " + maxRetries + " attempts. " + "Original cause: " + originalCause.getMessage(),