private Cluster getCluster()

in src/main/java/org/apache/fineract/cn/cassandra/core/CassandraSessionProvider.java [159:174]

• 12 lines of code
• 2 McCabe index (conditional complexity)

  private Cluster getCluster(@Nonnull final String clusterName, @Nonnull final String contactPoints) {
    CodecRegistry.register(new LocalDateTimeCodec());

    final Cluster.Builder clusterBuilder = Cluster.builder().withClusterName(clusterName);

    if (this.env.containsProperty(CassandraConnectorConstants.CLUSTER_USER_PROP)) {
      final String user = this.env.getProperty(CassandraConnectorConstants.CLUSTER_USER_PROP);
      final String pwd = this.env.getProperty(CassandraConnectorConstants.CLUSTER_PASSWORD_PROP);

      final AuthProvider authProvider = new PlainTextAuthProvider(user, pwd);
      clusterBuilder.withAuthProvider(authProvider);
    }

    ContactPointUtils.process(clusterBuilder, contactPoints);
    return clusterBuilder.build();
  }