- @Reference final ServiceRecoveryRegistry serviceRecoveryRegistry) {
- disableReconciliation = config.isDisableReconciliation();
- staleMarkingEnabled = config.isStaleMarkingEnabled();
- reconciliationRetryCount = config.getReconciliationRetryCount();
- isBundleBasedReconciliationEnabled = config.isBundleBasedReconciliationEnabled();
- this.configurationServiceRegistration = configurationService.registerListener(this);
- this.dataService = Preconditions.checkNotNull(dataBroker, "DataBroker can not be null!");
- this.clusterSingletonServiceProvider = Preconditions.checkNotNull(clusterSingletonService,
+ final ServiceRecoveryRegistry serviceRecoveryRegistry,
+ final FlowGroupCacheManager flowGroupCacheManager,
+ final ListenerRegistrationHelper registrationHelper) {
+ disableReconciliation = config.getDisableReconciliation();
+ staleMarkingEnabled = config.getStaleMarkingEnabled();
+ reconciliationRetryCount = config.getReconciliationRetryCount().toJava();
+ isBundleBasedReconciliationEnabled = config.getBundleBasedReconciliationEnabled();
+ configurationServiceRegistration = configurationService.registerListener(this);
+ this.registrationHelper = requireNonNull(registrationHelper, "RegistrationHelper cannot be null");
+ dataService = requireNonNull(dataBroker, "DataBroker can not be null!");
+ clusterSingletonServiceProvider = requireNonNull(clusterSingletonService,