X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=apps%2Fnetconf-topology%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fnetconf%2Ftopology%2Fspi%2FNetconfNodeHandler.java;h=a025c83cfba6d7cc873eaa6004709d838f0c4898;hb=493d1f617e491d0c4deb8f49079eecf0864f8d80;hp=82525479a70211833c50a35c930951daa75325f8;hpb=f87c8b6ee4275825ba7b3bd3c706be9e95f480f4;p=netconf.git

diff --git a/apps/netconf-topology/src/main/java/org/opendaylight/netconf/topology/spi/NetconfNodeHandler.java b/apps/netconf-topology/src/main/java/org/opendaylight/netconf/topology/spi/NetconfNodeHandler.java
index 82525479a7..a025c83cfb 100644
--- a/apps/netconf-topology/src/main/java/org/opendaylight/netconf/topology/spi/NetconfNodeHandler.java
+++ b/apps/netconf-topology/src/main/java/org/opendaylight/netconf/topology/spi/NetconfNodeHandler.java
@@ -19,7 +19,6 @@ import io.netty.util.Timer;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.concurrent.CancellationException;
-import java.util.concurrent.Executor;
 import java.util.concurrent.TimeUnit;
 import org.checkerframework.checker.lock.qual.GuardedBy;
 import org.checkerframework.checker.lock.qual.Holding;
@@ -130,7 +129,8 @@ public final class NetconfNodeHandler extends AbstractRegistration implements Re
 
     public NetconfNodeHandler(final NetconfClientFactory clientFactory, final Timer timer,
             final BaseNetconfSchemas baseSchemas, final SchemaResourceManager schemaManager,
-            final Executor processingExecutor, final NetconfClientConfigurationBuilderFactory builderFactory,
+            final NetconfTopologySchemaAssembler schemaAssembler,
+            final NetconfClientConfigurationBuilderFactory builderFactory,
             final DeviceActionFactory deviceActionFactory, final RemoteDeviceHandler delegate,
             final RemoteDeviceId deviceId, final NodeId nodeId, final NetconfNode node,
             final NetconfNodeAugmentedOptional nodeOptional) {
@@ -174,7 +174,7 @@ public final class NetconfNodeHandler extends AbstractRegistration implements Re
             device = new NetconfDeviceBuilder()
                 .setReconnectOnSchemasChange(node.requireReconnectOnChangedSchema())
                 .setSchemaResourcesDTO(resources)
-                .setGlobalProcessingExecutor(processingExecutor)
+                .setGlobalProcessingExecutor(schemaAssembler.executor())
                 .setId(deviceId)
                 .setSalFacade(salFacade)
                 .setDeviceActionFactory(deviceActionFactory)