- Configuration config = new ConfigurationImpl("module-shards.conf", "modules.conf");
- ClusterWrapper clusterWrapper = new ClusterWrapperImpl(actorSystem);
- DatastoreContextFactory contextFactory = introspector.newContextFactory();
+ final String datastoreName = initialDatastoreContext.getDataStoreName();
+ LOG.info("Create data store instance of type : {}", datastoreName);
+
+ final ActorSystem actorSystem = actorSystemProvider.getActorSystem();
+ final DatastoreSnapshot restoreFromSnapshot = datastoreSnapshotRestore.getAndRemove(datastoreName);
+
+ 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();