Improve property-based configuration

[openflowplugin.git] / openflowplugin-impl / src / main / java / org / opendaylight / openflowplugin / impl / rpc / RpcManagerImpl.java

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 f8cf02e33129af88bb267e8b06a786a3ab6aafc8..39eb472ca7d485ebbbcbcc52bc6b2f91246ffaf8 100644 (file)
--- 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);