| File was renamed from opendj-server-legacy/src/main/java/org/opends/server/backends/cassandra/Storage.java |
| | |
| | | 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); |
| | | } |
| | |
| | | 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)); |
| | |
| | | @Override |
| | | public void close() { |
| | | if (!isOpen) { |
| | | Storage.this.close(); |
| | | CASStorage.this.close(); |
| | | } |
| | | } |
| | | |