- dataService = requireNonNull(dataBroker, "DataBroker can not be null!");
- this.registrationHelper = requireNonNull(registrationHelper, "RegistrationHelper cannot be null");
- clusterSingletonServiceProvider = requireNonNull(clusterSingletonService,
- "ClusterSingletonService provider can not be null");
- this.reconciliationManager = reconciliationManager;
- this.rpcProviderService = rpcProviderService;
- this.mastershipChangeServiceManager = mastershipChangeServiceManager;
- this.flowGroupCacheManager = flowGroupCacheManager;
-
- Preconditions.checkArgument(rpcRegistry != null, "RpcProviderRegistry can not be null !");
+ dataService = requireNonNull(dataBroker);
+ clusterSingletonServiceProvider = requireNonNull(clusterSingletonService);