Rename DOMDataTreeCommitCohortRegistry to CommitCohortExtension

[mdsal.git] / dom / mdsal-dom-spi / src / main / java / org / opendaylight / mdsal / dom / spi / AbstractDOMDataBroker.java

diff --git a/dom/mdsal-dom-spi/src/main/java/org/opendaylight/mdsal/dom/spi/AbstractDOMDataBroker.java b/dom/mdsal-dom-spi/src/main/java/org/opendaylight/mdsal/dom/spi/AbstractDOMDataBroker.java
index a06d63febeddfe408c39892e7aec3cacbcb11c60..92144cd0688ecdb8fcf2eae82a3cb26b86a3846f 100644 (file)
--- a/dom/mdsal-dom-spi/src/main/java/org/opendaylight/mdsal/dom/spi/AbstractDOMDataBroker.java
+++ b/dom/mdsal-dom-spi/src/main/java/org/opendaylight/mdsal/dom/spi/AbstractDOMDataBroker.java
@@ -15,7 +15,6 @@ import java.util.concurrent.atomic.AtomicLong;
 import org.eclipse.jdt.annotation.NonNull;
 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
 import org.opendaylight.mdsal.dom.api.DOMDataTreeChangeService;
-import org.opendaylight.mdsal.dom.api.DOMDataTreeCommitCohortRegistry;
 import org.opendaylight.mdsal.dom.api.DOMTransactionChain;
 import org.opendaylight.mdsal.dom.spi.store.DOMStore;
 import org.opendaylight.mdsal.dom.spi.store.DOMStoreTransactionChain;
@@ -44,11 +43,11 @@ public abstract class AbstractDOMDataBroker extends AbstractDOMForwardedTransact
                 throw new IllegalStateException("Publisher for " + dsType + " data store is not available");
             });
         }
-        if (isSupported(datastores, DOMDataTreeCommitCohortRegistry.class)) {
-            builder.add((DOMDataTreeCommitCohortRegistry) (path, cohort) -> {
+        if (isSupported(datastores, CommitCohortExtension.class)) {
+            builder.add((CommitCohortExtension) (path, cohort) -> {
                 final var dsType = path.datastore();
-                if (getTxFactories().get(dsType) instanceof DOMDataTreeCommitCohortRegistry registry) {
-                    return registry.registerCommitCohort(path, cohort);
+                if (getTxFactories().get(dsType) instanceof CommitCohortExtension extension) {
+                    return extension.registerCommitCohort(path, cohort);
                 }
                 throw new IllegalStateException("Cohort registry for " + dsType + " data store is not available");
             });