X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=replicate%2Fmdsal-replicate-netty%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fmdsal%2Freplicate%2Fnetty%2FSourceRequestHandler.java;h=1f9a15e074b5859bd8616410a293ad30f207ffc0;hb=1487e0720cbb7f7b1f04507a85494c1a96dc82ad;hp=f0dfe0f6c5949fd1382719ea7f9fd82d1ac90fe2;hpb=0d2bd50cec7c53962a6c8af68710f04cd773c3a9;p=mdsal.git

diff --git a/replicate/mdsal-replicate-netty/src/main/java/org/opendaylight/mdsal/replicate/netty/SourceRequestHandler.java b/replicate/mdsal-replicate-netty/src/main/java/org/opendaylight/mdsal/replicate/netty/SourceRequestHandler.java
index f0dfe0f6c5..1f9a15e074 100644
--- a/replicate/mdsal-replicate-netty/src/main/java/org/opendaylight/mdsal/replicate/netty/SourceRequestHandler.java
+++ b/replicate/mdsal-replicate-netty/src/main/java/org/opendaylight/mdsal/replicate/netty/SourceRequestHandler.java
@@ -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());
         }