X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=netconf%2Ftools%2Fnetconf-cli%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fnetconf%2Fcli%2FNetconfDeviceConnectionManager.java;h=a3e98b31dad5fc96c2ede181fbe14290cbe1f7e5;hb=d86e82a7318555107ed957838b11e6b2ab5d9311;hp=2a73412d2c20166e51166f1cbb2701761aeeaef0;hpb=990f1c0d249e9f27e192cf6c1300e516ace81087;p=netconf.git

diff --git a/netconf/tools/netconf-cli/src/main/java/org/opendaylight/netconf/cli/NetconfDeviceConnectionManager.java b/netconf/tools/netconf-cli/src/main/java/org/opendaylight/netconf/cli/NetconfDeviceConnectionManager.java
index 2a73412d2c..a3e98b31da 100644
--- a/netconf/tools/netconf-cli/src/main/java/org/opendaylight/netconf/cli/NetconfDeviceConnectionManager.java
+++ b/netconf/tools/netconf-cli/src/main/java/org/opendaylight/netconf/cli/NetconfDeviceConnectionManager.java
@@ -24,7 +24,7 @@ import org.opendaylight.netconf.client.conf.NetconfClientConfigurationBuilder;
 import org.opendaylight.netconf.sal.connect.netconf.NetconfDevice;
 import org.opendaylight.netconf.sal.connect.netconf.NetconfDevice.SchemaResourcesDTO;
 import org.opendaylight.netconf.sal.connect.netconf.NetconfDeviceBuilder;
-import org.opendaylight.netconf.sal.connect.netconf.NetconfStateSchemas.NetconfStateSchemasResolverImpl;
+import org.opendaylight.netconf.sal.connect.netconf.NetconfStateSchemasResolverImpl;
 import org.opendaylight.netconf.sal.connect.netconf.listener.NetconfDeviceCommunicator;
 import org.opendaylight.netconf.sal.connect.util.RemoteDeviceId;
 import org.opendaylight.yangtools.yang.model.repo.api.SchemaContextFactory;
@@ -48,6 +48,7 @@ public class NetconfDeviceConnectionManager implements Closeable {
     private final NetconfClientDispatcherImpl netconfClientDispatcher;
 
     private static final String CACHE = "cache/schema";
+    private static final int RPC_LIMIT = 0;
 
     // Connection
     private NetconfDeviceConnectionHandler handler;
@@ -92,7 +93,8 @@ public class NetconfDeviceConnectionManager implements Closeable {
                 .setId(deviceId)
                 .setSalFacade(handler)
                 .build();
-        listener = new NetconfDeviceCommunicator(deviceId, device);
+        listener = new NetconfDeviceCommunicator(deviceId, device, RPC_LIMIT);
+
         configBuilder.withSessionListener(listener);
         listener.initializeRemoteConnection(netconfClientDispatcher, configBuilder.build());
     }