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%2FSourceSingletonService.java;h=22cc0c95f811d55a31538a4b6cd6a297abb9de02;hb=refs%2Fchanges%2F49%2F109849%2F5;hp=c86423e72ddbc7cbad77a7ddf8ac04ed621c3db8;hpb=7e9012b9820ed399a93d1f302dfa5c0e05583493;p=mdsal.git diff --git a/replicate/mdsal-replicate-netty/src/main/java/org/opendaylight/mdsal/replicate/netty/SourceSingletonService.java b/replicate/mdsal-replicate-netty/src/main/java/org/opendaylight/mdsal/replicate/netty/SourceSingletonService.java index c86423e72d..22cc0c95f8 100644 --- a/replicate/mdsal-replicate-netty/src/main/java/org/opendaylight/mdsal/replicate/netty/SourceSingletonService.java +++ b/replicate/mdsal-replicate-netty/src/main/java/org/opendaylight/mdsal/replicate/netty/SourceSingletonService.java @@ -26,7 +26,7 @@ import java.util.HashSet; import java.util.List; import java.util.concurrent.TimeUnit; import org.checkerframework.checker.lock.qual.GuardedBy; -import org.opendaylight.mdsal.dom.api.DOMDataTreeChangeService; +import org.opendaylight.mdsal.dom.api.DOMDataBroker.DataTreeChangeExtension; import org.opendaylight.mdsal.singleton.common.api.ClusterSingletonService; import org.opendaylight.mdsal.singleton.common.api.ServiceGroupIdentifier; import org.opendaylight.yangtools.yang.data.codec.binfmt.NormalizedNodeStreamVersion; @@ -43,7 +43,7 @@ final class SourceSingletonService extends ChannelInitializer imp new ServiceGroupIdentifier(SourceSingletonService.class.getName()); private final BootstrapSupport bootstrapSupport; - private final DOMDataTreeChangeService dtcs; + private final DataTreeChangeExtension dtcs; private final int listenPort; @GuardedBy("this") @@ -53,7 +53,7 @@ final class SourceSingletonService extends ChannelInitializer imp @GuardedBy("this") private Channel serverChannel; - SourceSingletonService(final BootstrapSupport bootstrapSupport, final DOMDataTreeChangeService dtcs, + SourceSingletonService(final BootstrapSupport bootstrapSupport, final DataTreeChangeExtension dtcs, final int listenPort, final Duration keepaliveInterval, final int maxMissedKeepalives) { this.bootstrapSupport = requireNonNull(bootstrapSupport); this.dtcs = requireNonNull(dtcs);