package org.opendaylight.controller.cluster.datastore;
+import akka.actor.ActorSystem;
+import org.opendaylight.controller.cluster.datastore.shardstrategy.ShardStrategyFactory;
import org.opendaylight.controller.sal.core.api.model.SchemaService;
public class DistributedDataStoreFactory {
public static DistributedDataStore createInstance(String name, SchemaService schemaService){
+ ActorSystem actorSystem = ActorSystemFactory.getInstance();
+ Configuration config = new ConfigurationImpl("module-shards.conf", "modules.conf");
final DistributedDataStore dataStore =
- new DistributedDataStore(ActorSystemFactory.getInstance(), name);
+ new DistributedDataStore(actorSystem, name, new ClusterWrapperImpl(actorSystem),config );
+ ShardStrategyFactory.setConfiguration(config);
schemaService
- .registerSchemaServiceListener(dataStore);
+ .registerSchemaContextListener(dataStore);
return dataStore;
}