- forwardingRulesManager = new ForwardingRulesManagerImpl(getDataBroker(), rpcProviderRegistryMock, getConfig(),
- clusterSingletonService, notificationService, getConfigurationService(), reconciliationManager,
- openflowServiceRecoveryHandler, serviceRecoveryRegistry);
-
+ forwardingRulesManager = new ForwardingRulesManagerImpl(getDataBroker(), rpcProviderRegistryMock,
+ rpcProviderRegistryMock, getConfig(), mastershipChangeServiceManager, clusterSingletonService,
+ getConfigurationService(), reconciliationManager, openflowServiceRecoveryHandler,
+ serviceRecoveryRegistry, flowGroupCacheManager);