private Connector createConnector()

in core/src/main/java/com/google/cloud/sql/core/InternalConnectorRegistry.java [306:340]

30 lines of code
5 McCabe index (conditional complexity)


  private Connector createConnector(ConnectorConfig config) {

    CredentialFactory instanceCredentialFactory =
        credentialFactoryProvider.getInstanceCredentialFactory(config);

    String universeDomain = config.getUniverseDomain();
    String credentialsUniverse;
    try {
      credentialsUniverse = instanceCredentialFactory.getCredentials().getUniverseDomain();
    } catch (IOException e) {
      throw new IllegalStateException("Fail to fetch the credential universe domain");
    }

    // Verify that the universe domain provided matches the credential universe domain.
    if (credentialsUniverse != null
        && universeDomain != null
        && !credentialsUniverse.equals(universeDomain)) {
      throw new IllegalStateException(
          String.format(
              "The configured universe domain (%s) does not match "
                  + "the credential universe domain (%s)",
              universeDomain, credentialsUniverse));
    }

    return new Connector(
        config,
        connectionInfoRepositoryFactory,
        instanceCredentialFactory,
        executor,
        localKeyPair,
        MIN_REFRESH_DELAY_MS,
        connectTimeoutMs,
        serverProxyPort,
        new DnsInstanceConnectionNameResolver(new JndiDnsResolver()));
  }