4 * Generated from: yang module name: opendaylight-sal-binding-broker-impl yang module local name: binding-broker-impl
\r
5 * Generated by: org.opendaylight.controller.config.yangjmxgenerator.plugin.JMXGenerator
\r
6 * Generated at: Wed Nov 20 17:33:01 CET 2013
\r
8 * Do not modify this file unless it is present under src/main directory
\r
10 package org.opendaylight.controller.config.yang.md.sal.binding.impl;
\r
12 import org.opendaylight.controller.sal.binding.codegen.impl.SingletonHolder;
\r
13 import org.opendaylight.controller.sal.binding.impl.RootBindingAwareBroker;
\r
14 import org.opendaylight.controller.sal.binding.impl.RpcProviderRegistryImpl;
\r
15 import org.opendaylight.controller.sal.binding.impl.forward.DomForwardedBindingBrokerImpl;
\r
16 import org.opendaylight.controller.sal.binding.impl.forward.DomForwardingUtils;
\r
17 import org.osgi.framework.BundleContext;
\r
19 import com.google.common.util.concurrent.MoreExecutors;
\r
24 public final class BindingBrokerImplModule extends
\r
25 org.opendaylight.controller.config.yang.md.sal.binding.impl.AbstractBindingBrokerImplModule {
\r
27 private BundleContext bundleContext;
\r
29 public BindingBrokerImplModule(org.opendaylight.controller.config.api.ModuleIdentifier identifier,
\r
30 org.opendaylight.controller.config.api.DependencyResolver dependencyResolver) {
\r
31 super(identifier, dependencyResolver);
\r
34 public BindingBrokerImplModule(org.opendaylight.controller.config.api.ModuleIdentifier identifier,
\r
35 org.opendaylight.controller.config.api.DependencyResolver dependencyResolver,
\r
36 BindingBrokerImplModule oldModule, java.lang.AutoCloseable oldInstance) {
\r
37 super(identifier, dependencyResolver, oldModule, oldInstance);
\r
41 public void validate() {
\r
46 public java.lang.AutoCloseable createInstance() {
\r
48 RootBindingAwareBroker broker;
\r
49 if (DomForwardingUtils.isDomForwardedBroker(getDataBrokerDependency())) {
\r
50 broker = createForwardedBroker();
\r
52 broker = createStandaloneBroker();
\r
58 private RootBindingAwareBroker createStandaloneBroker() {
\r
59 RootBindingAwareBroker broker = new RootBindingAwareBroker(getIdentifier().getInstanceName());
\r
61 broker.setDataBroker(getDataBrokerDependency());
\r
62 broker.setNotificationBroker(getNotificationServiceDependency());
\r
63 broker.setRpcBroker(new RpcProviderRegistryImpl(broker.getIdentifier()));
\r
67 private RootBindingAwareBroker createForwardedBroker() {
\r
68 DomForwardedBindingBrokerImpl broker = new DomForwardedBindingBrokerImpl(getIdentifier().getInstanceName());
\r
70 broker.setDataBroker(getDataBrokerDependency());
\r
71 broker.setNotificationBroker(getNotificationServiceDependency());
\r
72 broker.setRpcBroker(new RpcProviderRegistryImpl(broker.getIdentifier()));
\r
74 broker.getMountManager().setDataCommitExecutor(SingletonHolder.getDefaultCommitExecutor());
\r
75 broker.getMountManager().setNotificationExecutor(SingletonHolder.getDefaultNotificationExecutor());
\r
78 DomForwardingUtils.reuseForwardingFrom(broker, broker.getDataBroker());
\r
79 broker.startForwarding();
\r
83 public BundleContext getBundleContext() {
\r
84 return bundleContext;
\r
87 public void setBundleContext(BundleContext bundleContext) {
\r
88 this.bundleContext = bundleContext;
\r