X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatabroker%2FAbstractDOMBroker.java;h=d17de224a01f26cf70f39b147f8ff5b80e68a8b7;hp=833cb4946230f559a11bacea5bea7da99aa11180;hb=b00bee7547dbba0677347e991a8674f90752f6a2;hpb=9fb1df14f2dc885fee1dce821b753cc99af6e54f diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/databroker/AbstractDOMBroker.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/databroker/AbstractDOMBroker.java index 833cb49462..d17de224a0 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/databroker/AbstractDOMBroker.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/databroker/AbstractDOMBroker.java @@ -9,6 +9,7 @@ package org.opendaylight.controller.cluster.databroker; import static com.google.common.base.Preconditions.checkState; + import com.google.common.collect.ImmutableMap; import java.util.Collections; import java.util.EnumMap; @@ -31,8 +32,8 @@ import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -public abstract class AbstractDOMBroker extends AbstractDOMTransactionFactory - implements DOMDataBroker, AutoCloseable { +abstract class AbstractDOMBroker extends AbstractDOMTransactionFactory + implements DOMDataBroker { private static final Logger LOG = LoggerFactory.getLogger(AbstractDOMBroker.class); @@ -53,13 +54,15 @@ public abstract class AbstractDOMBroker extends AbstractDOMTransactionFactory, DOMDataBrokerExtension>of(DOMDataTreeChangeService.class, new DOMDataTreeChangeService() { + extensions = ImmutableMap.of(DOMDataTreeChangeService.class, new DOMDataTreeChangeService() { @Override - public ListenerRegistration registerDataTreeChangeListener(final DOMDataTreeIdentifier treeId, final L listener) { + public ListenerRegistration registerDataTreeChangeListener( + final DOMDataTreeIdentifier treeId, final L listener) { DOMStore publisher = getTxFactories().get(treeId.getDatastoreType()); checkState(publisher != null, "Requested logical data store is not available."); - return ((DOMStoreTreeChangePublisher) publisher).registerTreeChangeListener(treeId.getRootIdentifier(), listener); + return ((DOMStoreTreeChangePublisher) publisher).registerTreeChangeListener( + treeId.getRootIdentifier(), listener); } }); } else { @@ -72,6 +75,7 @@ public abstract class AbstractDOMBroker extends AbstractDOMTransactionFactory registerDataChangeListener(final LogicalDatastoreType store, - final YangInstanceIdentifier path, final DOMDataChangeListener listener, final DataChangeScope triggeringScope) { - + final YangInstanceIdentifier path, final DOMDataChangeListener listener, + final DataChangeScope triggeringScope) { DOMStore potentialStore = getTxFactories().get(store); checkState(potentialStore != null, "Requested logical data store is not available."); return potentialStore.registerChangeListener(path, listener, triggeringScope); @@ -107,7 +111,8 @@ public abstract class AbstractDOMBroker extends AbstractDOMTransactionFactory backingChains = new EnumMap<>(LogicalDatastoreType.class); + final Map backingChains = + new EnumMap<>(LogicalDatastoreType.class); for (Map.Entry entry : getTxFactories().entrySet()) { backingChains.put(entry.getKey(), entry.getValue().createTransactionChain()); }