X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;ds=sidebyside;f=apps%2Fnetconf-topology-singleton%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fnetconf%2Ftopology%2Fsingleton%2Fimpl%2Factors%2FNetconfNodeActor.java;fp=apps%2Fnetconf-topology-singleton%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fnetconf%2Ftopology%2Fsingleton%2Fimpl%2Factors%2FNetconfNodeActor.java;h=c58716c2aa6e100ae11bb50b846a487602b26f70;hb=1d6e9d80cc41e7d500635b2b961427d5f0fb2aff;hp=12b8350372e04764b880f7f89fe71d2d1b855410;hpb=4e2a180f4ef132bbe3c356590f41ecaaa92a8ef0;p=netconf.git

diff --git a/apps/netconf-topology-singleton/src/main/java/org/opendaylight/netconf/topology/singleton/impl/actors/NetconfNodeActor.java b/apps/netconf-topology-singleton/src/main/java/org/opendaylight/netconf/topology/singleton/impl/actors/NetconfNodeActor.java
index 12b8350372..c58716c2aa 100644
--- a/apps/netconf-topology-singleton/src/main/java/org/opendaylight/netconf/topology/singleton/impl/actors/NetconfNodeActor.java
+++ b/apps/netconf-topology-singleton/src/main/java/org/opendaylight/netconf/topology/singleton/impl/actors/NetconfNodeActor.java
@@ -333,7 +333,18 @@ public class NetconfNodeActor extends AbstractUntypedActor {
                         final var rpcProxy = new ProxyDOMRpcService(actorSystem, masterReference, id,
                             actorResponseWaitTime);
                         slaveSalManager.registerSlaveMountPoint(result, masterReference, new RemoteDeviceServices(
-                            (Rpcs.Normalized) () -> rpcProxy,
+                            new Rpcs.Normalized() {
+                                @Override
+                                public ListenableFuture<? extends DOMRpcResult> invokeNetconf(final QName type,
+                                        final ContainerNode input) {
+                                    return rpcProxy.invokeRpc(type, input);
+                                }
+
+                                @Override
+                                public DOMRpcService domRpcService() {
+                                    return rpcProxy;
+                                }
+                            },
                             new ProxyDOMActionService(actorSystem, masterReference, id, actorResponseWaitTime)));
                     }
                 });