- private final long echoReplyTimeout;
- private final ThreadPoolExecutor threadPool;
-
- public ConnectionManagerImpl(long echoReplyTimeout, final ThreadPoolExecutor threadPool) {
- this.echoReplyTimeout = echoReplyTimeout;
- this.threadPool = threadPool;
+ private final OpenflowProviderConfig config;
+ private final ExecutorService executorService;
+ private final DeviceConnectionRateLimiter deviceConnectionRateLimiter;
+ private DeviceDisconnectedHandler deviceDisconnectedHandler;
+
+ public ConnectionManagerImpl(final OpenflowProviderConfig config, final ExecutorService executorService) {
+ this.config = config;
+ this.executorService = executorService;
+ this.deviceConnectionRateLimiter = new DeviceConnectionRateLimiter(config);