- new DistributedDataStore(ActorSystemFactory.getInstance(), name);
- schemaService
- .registerSchemaServiceListener(dataStore);
+ new DistributedDataStore(actorSystem, name, new ClusterWrapperImpl(actorSystem),
+ config, dataStoreProperties );
+ ShardStrategyFactory.setConfiguration(config);
+ schemaService.registerSchemaContextListener(dataStore);