1 package org.opendaylight.controller.config.yang.config.distributed_datastore_provider;
3 import org.opendaylight.controller.cluster.datastore.DistributedDataStoreFactory;
4 import org.opendaylight.controller.cluster.datastore.DistributedDataStoreProperties;
5 import org.osgi.framework.BundleContext;
7 public class DistributedConfigDataStoreProviderModule extends
8 org.opendaylight.controller.config.yang.config.distributed_datastore_provider.AbstractDistributedConfigDataStoreProviderModule {
9 private BundleContext bundleContext;
11 public DistributedConfigDataStoreProviderModule(
12 org.opendaylight.controller.config.api.ModuleIdentifier identifier,
13 org.opendaylight.controller.config.api.DependencyResolver dependencyResolver) {
14 super(identifier, dependencyResolver);
17 public DistributedConfigDataStoreProviderModule(
18 org.opendaylight.controller.config.api.ModuleIdentifier identifier,
19 org.opendaylight.controller.config.api.DependencyResolver dependencyResolver,
20 org.opendaylight.controller.config.yang.config.distributed_datastore_provider.DistributedConfigDataStoreProviderModule oldModule,
21 java.lang.AutoCloseable oldInstance) {
22 super(identifier, dependencyResolver, oldModule, oldInstance);
26 public void customValidation() {
27 // add custom validation form module attributes here.
31 public java.lang.AutoCloseable createInstance() {
33 ConfigProperties props = getConfigProperties();
35 props = new ConfigProperties();
38 return DistributedDataStoreFactory.createInstance("config", getConfigSchemaServiceDependency(),
39 new DistributedDataStoreProperties(
40 props.getMaxShardDataChangeExecutorPoolSize().getValue(),
41 props.getMaxShardDataChangeExecutorQueueSize().getValue(),
42 props.getMaxShardDataChangeListenerQueueSize().getValue(),
43 props.getShardTransactionIdleTimeoutInMinutes().getValue(),
44 props.getOperationTimeoutInSeconds().getValue()), bundleContext);
47 public void setBundleContext(BundleContext bundleContext) {
48 this.bundleContext = bundleContext;