import static com.google.common.base.Preconditions.checkState;
+import org.opendaylight.mdsal.dom.store.inmemory.InMemoryDOMDataStore;
+
+import org.opendaylight.mdsal.dom.spi.store.DOMStore;
+import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
import com.google.common.annotations.Beta;
-import com.google.common.collect.ImmutableClassToInstanceMap;
import com.google.common.collect.ImmutableMap;
import com.google.common.collect.ImmutableSet;
import com.google.common.util.concurrent.ListeningExecutorService;
import com.google.common.util.concurrent.MoreExecutors;
import javassist.ClassPool;
-import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
-import org.opendaylight.controller.md.sal.dom.store.impl.InMemoryDOMDataStore;
-import org.opendaylight.controller.sal.binding.api.BindingAwareService;
-import org.opendaylight.controller.sal.binding.api.RpcProviderRegistry;
-import org.opendaylight.controller.sal.binding.impl.RootBindingAwareBroker;
-import org.opendaylight.controller.sal.core.spi.data.DOMStore;
import org.opendaylight.mdsal.binding.api.DataBroker;
import org.opendaylight.mdsal.binding.api.MountPointService;
import org.opendaylight.mdsal.binding.api.NotificationPublishService;
private BindingToNormalizedNodeCodec codec;
- private RootBindingAwareBroker baBrokerImpl;
-
private final ListeningExecutorService executor;
private final ClassPool classPool;
baConsumerRpc = new BindingDOMRpcServiceAdapter(getDomRpcInvoker(), codec);
baProviderRpc = new BindingDOMRpcProviderServiceAdapter(getDomRpcRegistry(), codec);
final MountPointService mountService = new BindingDOMMountPointServiceAdapter(biMountImpl, codec);
-
- final ImmutableClassToInstanceMap<BindingAwareService> consumerServices =
- ImmutableClassToInstanceMap.<BindingAwareService>builder().build();
- final ImmutableClassToInstanceMap<BindingAwareService> providerServices =
- ImmutableClassToInstanceMap.<BindingAwareService>builder().build();;
- baBrokerImpl = new RootBindingAwareBroker("test", consumerServices, providerServices);
}
public void startForwarding() {
updateYangSchema(moduleInfos);
}
-
-
- public RpcProviderRegistry getBindingRpcRegistry() {
- return baBrokerImpl.getRpcProviderRegistry();
- }
-
public DOMRpcProviderService getDomRpcRegistry() {
return domRouter;
}