X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2FDistributedDataStoreFactory.java;h=4d3854f9ef4e7dc83bde887ecceb6cf1eda604c0;hb=2eddbcc5db186af5b5feacfe5d7056e2f3dccd38;hp=ee8ac61ecf6da73a410a1ebc87315389dd715d42;hpb=db0dbb7e7976efc860012dfdba61d5416d45900c;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DistributedDataStoreFactory.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DistributedDataStoreFactory.java index ee8ac61ecf..4d3854f9ef 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DistributedDataStoreFactory.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DistributedDataStoreFactory.java @@ -15,8 +15,9 @@ import com.typesafe.config.ConfigFactory; import java.util.HashSet; import java.util.Set; import java.util.concurrent.TimeUnit; -import org.opendaylight.controller.cluster.datastore.config.ConfigurationReader; -import org.opendaylight.controller.cluster.datastore.shardstrategy.ShardStrategyFactory; +import org.opendaylight.controller.cluster.common.actor.AkkaConfigurationReader; +import org.opendaylight.controller.cluster.datastore.config.Configuration; +import org.opendaylight.controller.cluster.datastore.config.ConfigurationImpl; import org.opendaylight.controller.sal.core.api.model.SchemaService; import org.osgi.framework.BundleContext; import org.slf4j.Logger; @@ -46,7 +47,6 @@ public class DistributedDataStoreFactory { overlay.setListener(dataStore); - ShardStrategyFactory.setConfiguration(config); schemaService.registerSchemaContextListener(dataStore); dataStore.setCloseable(overlay); @@ -57,7 +57,7 @@ public class DistributedDataStoreFactory { } private static synchronized final ActorSystem getActorSystem(final BundleContext bundleContext, - ConfigurationReader configurationReader) { + AkkaConfigurationReader configurationReader) { if (actorSystem == null) { // Create an OSGi bundle classloader for actor system BundleDelegatingClassLoader classLoader = new BundleDelegatingClassLoader(bundleContext.getBundle(),