1 package org.opendaylight.controller.config.yang.config.cluster_admin_provider;
3 import com.google.common.base.Preconditions;
4 import org.opendaylight.controller.cluster.datastore.DistributedDataStore;
5 import org.opendaylight.controller.cluster.datastore.admin.ClusterAdminRpcService;
6 import org.opendaylight.controller.config.api.DependencyResolver;
7 import org.opendaylight.controller.config.api.ModuleIdentifier;
9 public class ClusterAdminProviderModule extends AbstractClusterAdminProviderModule {
10 public ClusterAdminProviderModule(ModuleIdentifier identifier, DependencyResolver dependencyResolver) {
11 super(identifier, dependencyResolver);
14 public ClusterAdminProviderModule(ModuleIdentifier identifier, DependencyResolver dependencyResolver,
15 ClusterAdminProviderModule oldModule, java.lang.AutoCloseable oldInstance) {
16 super(identifier, dependencyResolver, oldModule, oldInstance);
20 public void customValidation() {
21 // add custom validation form module attributes here.
25 public AutoCloseable createInstance() {
26 Preconditions.checkArgument(getConfigDataStoreDependency() instanceof DistributedDataStore,
27 "Injected config DOMStore must be an instance of DistributedDataStore");
28 Preconditions.checkArgument(getOperDataStoreDependency() instanceof DistributedDataStore,
29 "Injected operational DOMStore must be an instance of DistributedDataStore");
30 ClusterAdminRpcService service = new ClusterAdminRpcService((DistributedDataStore)getConfigDataStoreDependency(),
31 (DistributedDataStore)getOperDataStoreDependency());
32 service.start(getRpcRegistryDependency());