X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=netconf%2Fnetconf-topology-singleton%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fnetconf%2Ftopology%2Fsingleton%2Fimpl%2FSlaveSalFacade.java;h=fd1c28a0ade3aecedd083b572263c0ac943d2ed7;hb=f273cff9baab6d3bd6a93214b639ecab7061e242;hp=877436d6cc1d637a525249e775e56f6fa4f3c5d7;hpb=e7149587aacbb9a2afae4f89db6976574588ac47;p=netconf.git diff --git a/netconf/netconf-topology-singleton/src/main/java/org/opendaylight/netconf/topology/singleton/impl/SlaveSalFacade.java b/netconf/netconf-topology-singleton/src/main/java/org/opendaylight/netconf/topology/singleton/impl/SlaveSalFacade.java index 877436d6cc..fd1c28a0ad 100644 --- a/netconf/netconf-topology-singleton/src/main/java/org/opendaylight/netconf/topology/singleton/impl/SlaveSalFacade.java +++ b/netconf/netconf-topology-singleton/src/main/java/org/opendaylight/netconf/topology/singleton/impl/SlaveSalFacade.java @@ -10,6 +10,7 @@ package org.opendaylight.netconf.topology.singleton.impl; import akka.actor.ActorRef; import akka.actor.ActorSystem; +import akka.util.Timeout; import org.opendaylight.controller.md.sal.dom.api.DOMRpcService; import org.opendaylight.controller.sal.core.api.Broker; import org.opendaylight.netconf.sal.connect.netconf.sal.NetconfDeviceNotificationService; @@ -29,13 +30,16 @@ public class SlaveSalFacade { private final NetconfDeviceSalProvider salProvider; private final ActorSystem actorSystem; + private final Timeout actorResponseWaitTime; public SlaveSalFacade(final RemoteDeviceId id, final Broker domBroker, - final ActorSystem actorSystem) { + final ActorSystem actorSystem, + final Timeout actorResponseWaitTime) { this.id = id; this.salProvider = new NetconfDeviceSalProvider(id); this.actorSystem = actorSystem; + this.actorResponseWaitTime = actorResponseWaitTime; registerToSal(domBroker); } @@ -50,7 +54,7 @@ public class SlaveSalFacade { final NetconfDeviceNotificationService notificationService = new NetconfDeviceNotificationService(); final NetconfDOMTransaction proxyDOMTransactions = - new NetconfProxyDOMTransaction(id, actorSystem, masterActorRef); + new NetconfProxyDOMTransaction(id, actorSystem, masterActorRef, actorResponseWaitTime); final NetconfDOMDataBroker netconfDeviceDataBroker = new NetconfDOMDataBroker(actorSystem, id, proxyDOMTransactions); @@ -69,7 +73,7 @@ public class SlaveSalFacade { unregisterSlaveMountPoint(); try { salProvider.getMountInstance().close(); - } catch (Exception exception) { + } catch (final Exception exception) { LOG.warn("{}: Exception in closing slave sal facade: {}", id, exception); }