mirror of https://github.com/OpenIdentityPlatform/OpenDJ.git

Valery Kharseko
yesterday 6356883aae48bd09070693eb0e324e2765022983
opendj-server-legacy/src/main/java/org/opends/server/backends/cassandra/CASStorage.java
File was renamed from opendj-server-legacy/src/main/java/org/opends/server/backends/cassandra/Storage.java
@@ -66,13 +66,13 @@
import com.github.benmanes.caffeine.cache.Caffeine;
import com.github.benmanes.caffeine.cache.LoadingCache;
public class Storage implements org.opends.server.backends.pluggable.spi.Storage, ConfigurationChangeListener<CASBackendCfg>{
public class CASStorage implements org.opends.server.backends.pluggable.spi.Storage, ConfigurationChangeListener<CASBackendCfg>{
   
   private static final LocalizedLogger logger = LocalizedLogger.getLoggerForThisClass();
   private CASBackendCfg config;
   
   public Storage(CASBackendCfg cfg, ServerContext serverContext) {
   public CASStorage(CASBackendCfg cfg, ServerContext serverContext) {
      this.config = cfg;
      cfg.addCASChangeListener(this);
   }
@@ -123,7 +123,7 @@
      this.accessMode=accessMode;
      session=CqlSession.builder()
         .withApplicationName("OpenDJ "+getKeyspaceName()+"."+config.getBackendId())
         .withConfigLoader(DriverConfigLoader.fromDefaults(Storage.class.getClassLoader()))
         .withConfigLoader(DriverConfigLoader.fromDefaults(CASStorage.class.getClassLoader()))
         .build();
      if (AccessMode.READ_WRITE.equals(accessMode)) {
         execute(prepared.get("CREATE KEYSPACE IF NOT EXISTS "+getKeyspaceName()+" WITH replication = {'class': 'SimpleStrategy', 'replication_factor': '1'};").bind().setExecutionProfileName(profile));
@@ -450,7 +450,7 @@
      @Override
      public void close() {
         if (!isOpen) {
            Storage.this.close();
            CASStorage.this.close();
         }
      }