final DistributedDataStore dataStore = new DistributedDataStore(actorSystem,
new ClusterWrapperImpl(actorSystem), config, introspector.getContext());
+ overlay.setListener(dataStore);
+
ShardStrategyFactory.setConfiguration(config);
schemaService.registerSchemaContextListener(dataStore);
dataStore.setCloseable(overlay);
+ dataStore.waitTillReady();
return dataStore;
}