- final ActorSystem actorSystem = ActorSystem.create("opendaylight-cluster-system", ConfigFactory
- .load().getConfig("ODLCluster"));
-
-
- final DistributedDataStore configDatastore = new DistributedDataStore(actorSystem, "config");
- getSchemaServiceDependency().registerSchemaServiceListener(configDatastore);
-
- final class AutoCloseableDistributedDataStore implements AutoCloseable {
-
- @Override
- public void close() throws Exception {
- actorSystem.shutdown();
- }
- }
-
- return new AutoCloseableDistributedDataStore();
+ return DistributedDataStoreFactory
+ .createInstance("config", getSchemaServiceDependency());