1 package org.opendaylight.controller.sal.dom.broker;
3 import java.util.concurrent.atomic.AtomicLong;
5 import org.opendaylight.controller.md.sal.common.api.data.DataChangeEvent;
6 import org.opendaylight.controller.md.sal.common.api.data.DataReader;
7 import org.opendaylight.controller.md.sal.common.impl.service.AbstractDataBroker;
8 import org.opendaylight.controller.sal.common.DataStoreIdentifier;
9 import org.opendaylight.controller.sal.core.api.data.DataChangeListener;
10 import org.opendaylight.controller.sal.core.api.data.DataProviderService;
11 import org.opendaylight.controller.sal.core.api.data.DataValidator;
12 import org.opendaylight.controller.sal.dom.broker.impl.DataReaderRouter;
13 import org.opendaylight.yangtools.concepts.Registration;
14 import org.opendaylight.yangtools.yang.data.api.CompositeNode;
15 import org.opendaylight.yangtools.yang.data.api.InstanceIdentifier;
17 public class DataBrokerImpl extends AbstractDataBroker<InstanceIdentifier, CompositeNode, DataChangeListener> implements
20 public DataBrokerImpl() {
21 setDataReadRouter(new DataReaderRouter());
24 private AtomicLong nextTransaction = new AtomicLong();
27 public DataTransactionImpl beginTransaction() {
28 String transactionId = "DOM-" + nextTransaction.getAndIncrement();
29 return new DataTransactionImpl(transactionId,this);
33 public Registration<DataReader<InstanceIdentifier, CompositeNode>> registerConfigurationReader(
34 InstanceIdentifier path, DataReader<InstanceIdentifier, CompositeNode> reader) {
35 return getDataReadRouter().registerConfigurationReader(path, reader);
39 public Registration<DataReader<InstanceIdentifier, CompositeNode>> registerOperationalReader(
40 InstanceIdentifier path, DataReader<InstanceIdentifier, CompositeNode> reader) {
41 return getDataReadRouter().registerOperationalReader(path, reader);
46 public void addValidator(DataStoreIdentifier store, DataValidator validator) {
47 throw new UnsupportedOperationException("Deprecated");
53 public void removeValidator(DataStoreIdentifier store, DataValidator validator) {
54 throw new UnsupportedOperationException("Deprecated");
59 public void addRefresher(DataStoreIdentifier store, DataRefresher refresher) {
60 throw new UnsupportedOperationException("Deprecated");
65 public void removeRefresher(DataStoreIdentifier store, DataRefresher refresher) {
66 throw new UnsupportedOperationException("Deprecated");