X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=openflowplugin-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fopenflowplugin%2Fimpl%2Frpc%2FRpcManagerImpl.java;fp=openflowplugin-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fopenflowplugin%2Fimpl%2Frpc%2FRpcManagerImpl.java;h=39eb472ca7d485ebbbcbcc52bc6b2f91246ffaf8;hb=c94d17e938e1577e25f0743eb3d31f8ffc49529d;hp=f8cf02e33129af88bb267e8b06a786a3ab6aafc8;hpb=438465fbd0748e1b6d76a18facb38912774412bd;p=openflowplugin.git

diff --git a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/rpc/RpcManagerImpl.java b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/rpc/RpcManagerImpl.java
index f8cf02e331..39eb472ca7 100644
--- a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/rpc/RpcManagerImpl.java
+++ b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/rpc/RpcManagerImpl.java
@@ -36,7 +36,7 @@ public class RpcManagerImpl implements RpcManager {
     private final RpcProviderRegistry rpcProviderRegistry;
     private DeviceInitializationPhaseHandler deviceInitPhaseHandler;
     private DeviceTerminationPhaseHandler deviceTerminationPhaseHandler;
-    private final int maxRequestsQuota;
+    private int maxRequestsQuota;
     private final ConcurrentMap<DeviceInfo, RpcContext> contexts = new ConcurrentHashMap<>();
     private boolean isStatisticsRpcEnabled;
     private final ExtensionConverterProvider extensionConverterProvider;
@@ -46,12 +46,10 @@ public class RpcManagerImpl implements RpcManager {
 
     public RpcManagerImpl(
             final RpcProviderRegistry rpcProviderRegistry,
-            final int quotaValue,
             final ExtensionConverterProvider extensionConverterProvider,
 	        final ConvertorExecutor convertorExecutor,
             final NotificationPublishService notificationPublishService) {
         this.rpcProviderRegistry = rpcProviderRegistry;
-        maxRequestsQuota = quotaValue;
         this.extensionConverterProvider = extensionConverterProvider;
         this.convertorExecutor = convertorExecutor;
         this.notificationPublishService = notificationPublishService;
@@ -122,6 +120,11 @@ public class RpcManagerImpl implements RpcManager {
         isStatisticsRpcEnabled = statisticsRpcEnabled;
     }
 
+    @Override
+    public void setRpcRequestQuota(final int rpcRequestQuota) {
+        this.maxRequestsQuota = rpcRequestQuota;
+    }
+
     @Override
     public void onDeviceRemoved(DeviceInfo deviceInfo) {
         contexts.remove(deviceInfo);