public CassandraSessionProvider cassandraSessionProvider()

in src/main/java/org/apache/fineract/cn/cassandra/config/CassandraConnectorConfiguration.java [60:72]

• 11 lines of code
• 1 McCabe index (conditional complexity)

  public CassandraSessionProvider cassandraSessionProvider(@Qualifier(CassandraConnectorConstants.LOGGER_NAME) final Logger logger) {
    final CassandraSessionProvider cassandraSessionProvider = new CassandraSessionProvider(this.env, logger);
    cassandraSessionProvider.setAdminClusterName(
        this.env.getProperty(CassandraConnectorConstants.CLUSTER_NAME_PROP, CassandraConnectorConstants.CLUSTER_NAME_PROP_DEFAULT));
    cassandraSessionProvider.setAdminContactPoints(
        this.env.getProperty(CassandraConnectorConstants.CONTACT_POINTS_PROP, CassandraConnectorConstants.CONTACT_POINTS_PROP_DEFAULT));
    cassandraSessionProvider.setAdminKeyspace(
        this.env.getProperty(CassandraConnectorConstants.KEYSPACE_PROP, CassandraConnectorConstants.KEYSPACE_PROP_DEFAULT));

    cassandraSessionProvider.touchAdminSession();

    return cassandraSessionProvider;
  }