Rename DOMDataTreeChangeService
[mdsal.git] / replicate / mdsal-replicate-netty / src / main / java / org / opendaylight / mdsal / replicate / netty / SourceRequestHandler.java
index f0dfe0f6c5949fd1382719ea7f9fd82d1ac90fe2..1f9a15e074b5859bd8616410a293ad30f207ffc0 100644 (file)
@@ -19,7 +19,7 @@ import java.io.IOException;
 import java.util.List;
 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
 import org.opendaylight.mdsal.dom.api.ClusteredDOMDataTreeChangeListener;
-import org.opendaylight.mdsal.dom.api.DOMDataTreeChangeService;
+import org.opendaylight.mdsal.dom.api.DOMDataBroker.DataTreeChangeExtension;
 import org.opendaylight.mdsal.dom.api.DOMDataTreeIdentifier;
 import org.opendaylight.yangtools.concepts.Registration;
 import org.opendaylight.yangtools.yang.data.codec.binfmt.NormalizedNodeDataInput;
@@ -33,11 +33,11 @@ import org.slf4j.LoggerFactory;
 final class SourceRequestHandler extends SimpleChannelInboundHandler<ByteBuf> {
     private static final Logger LOG = LoggerFactory.getLogger(SourceRequestHandler.class);
 
-    private final DOMDataTreeChangeService dtcs;
+    private final DataTreeChangeExtension dtcs;
 
     private Registration reg;
 
-    SourceRequestHandler(final DOMDataTreeChangeService dtcs) {
+    SourceRequestHandler(final DataTreeChangeExtension dtcs) {
         this.dtcs = requireNonNull(dtcs);
     }
 
@@ -80,7 +80,7 @@ final class SourceRequestHandler extends SimpleChannelInboundHandler<ByteBuf> {
         try (var input = new ByteBufInputStream(msg)) {
             final var normalizedInput = NormalizedNodeDataInput.newDataInput(input);
 
-            dataTree = new DOMDataTreeIdentifier(LogicalDatastoreType.readFrom(normalizedInput),
+            dataTree = DOMDataTreeIdentifier.of(LogicalDatastoreType.readFrom(normalizedInput),
                 normalizedInput.readYangInstanceIdentifier());
         }