- public static synchronized void destroyInstance(DistributedDataStore dataStore){
- Preconditions.checkNotNull(dataStore, "dataStore should not be null");
-
- LOG.info("Destroy data store instance of type : {}", dataStore.getActorContext().getDataStoreType());
-
- if(createdInstances.remove(dataStore)){
- if(createdInstances.size() == 0){
- if(actorSystem != null) {
- actorSystem.shutdown();
- try {
- actorSystem.awaitTermination(Duration.create(10, TimeUnit.SECONDS));
- } catch (Exception e) {
- LOG.warn("Error awaiting actor termination", e);
- }
- actorSystem = null;
- }
- }
+ final Configuration config;
+ if (orgConfig == null) {
+ config = new ConfigurationImpl(DEFAULT_MODULE_SHARDS_PATH, DEFAULT_MODULES_PATH);
+ } else {
+ config = orgConfig;
+ }
+ final ClusterWrapper clusterWrapper = new ClusterWrapperImpl(actorSystem);
+ final DatastoreContextFactory contextFactory = introspector.newContextFactory();
+
+ // This is the potentially-updated datastore context, distinct from the initial one
+ final DatastoreContext datastoreContext = contextFactory.getBaseDatastoreContext();
+
+ final AbstractDataStore dataStore;
+ if (datastoreContext.isUseTellBasedProtocol()) {
+ dataStore = new ClientBackedDataStore(actorSystem, clusterWrapper, config, contextFactory,
+ restoreFromSnapshot);
+ LOG.info("Data store {} is using tell-based protocol", datastoreName);
+ } else {
+ dataStore = new DistributedDataStore(actorSystem, clusterWrapper, config, contextFactory,
+ restoreFromSnapshot);
+ LOG.info("Data store {} is using ask-based protocol", datastoreName);