- ActorSystem actorSystem = getOrCreateInstance(bundleContext);
- Configuration config = new ConfigurationImpl("module-shards.conf", "modules.conf");
- final DistributedDataStore dataStore =
- new DistributedDataStore(actorSystem, name, new ClusterWrapperImpl(actorSystem),
- config, datastoreContext);
-
- ShardStrategyFactory.setConfiguration(config);
- schemaService.registerSchemaContextListener(dataStore);
- return dataStore;
- }