public Session getTenantSession()

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

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

  public Session getTenantSession(@Nonnull final String identifier) {
    Assert.notNull(identifier, "A tenant identifier must be given.");
    Assert.hasText(identifier, "A tenant identifier must be given.");

    final Mapper<Tenant> tenantInfoMapper = this.getAdminSessionMappingManager().mapper(Tenant.class);
    tenantInfoMapper.setDefaultDeleteOptions(OptionProvider.deleteConsistencyLevel(this.env));
    tenantInfoMapper.setDefaultGetOptions(OptionProvider.readConsistencyLevel(this.env));
    tenantInfoMapper.setDefaultSaveOptions(OptionProvider.writeConsistencyLevel(this.env));
    final Tenant tenantInfo = tenantInfoMapper.get(identifier);
    if (tenantInfo == null) throw ServiceException.notFound("Tenant [" + identifier + "] unknown.");
    return this.getSession(tenantInfo.getClusterName(), tenantInfo.getContactPoints(), tenantInfo.getKeyspace());
  }