1 package org.opendaylight.controller.config.yang.config.distributed_datastore_provider;
3 import akka.actor.ActorSystem;
4 import com.typesafe.config.ConfigFactory;
5 import org.opendaylight.controller.cluster.datastore.DistributedDataStore;
7 public class DistributedOperationalDataStoreProviderModule extends org.opendaylight.controller.config.yang.config.distributed_datastore_provider.AbstractDistributedOperationalDataStoreProviderModule {
8 public DistributedOperationalDataStoreProviderModule(org.opendaylight.controller.config.api.ModuleIdentifier identifier, org.opendaylight.controller.config.api.DependencyResolver dependencyResolver) {
9 super(identifier, dependencyResolver);
12 public DistributedOperationalDataStoreProviderModule(org.opendaylight.controller.config.api.ModuleIdentifier identifier, org.opendaylight.controller.config.api.DependencyResolver dependencyResolver, org.opendaylight.controller.config.yang.config.distributed_datastore_provider.DistributedOperationalDataStoreProviderModule oldModule, java.lang.AutoCloseable oldInstance) {
13 super(identifier, dependencyResolver, oldModule, oldInstance);
17 public void customValidation() {
18 // add custom validation form module attributes here.
22 public java.lang.AutoCloseable createInstance() {
23 final ActorSystem actorSystem = ActorSystem.create("opendaylight-cluster", ConfigFactory
24 .load().getConfig("ODLCluster"));
25 final DistributedDataStore operationalStore = new DistributedDataStore(actorSystem, "operational");
26 getSchemaServiceDependency().registerSchemaServiceListener(operationalStore);
28 final class AutoCloseableDistributedDataStore implements AutoCloseable {
31 public void close() throws Exception {
32 actorSystem.shutdown();
36 return new AutoCloseableDistributedDataStore();