- this.converterExecutor = convertorExecutor;
- this.controlServiceRegistration = Preconditions.checkNotNull(rpcProviderRegistry
- .registerRpcImplementation(StatisticsManagerControlService.class, this));
- this.executorService = executorService;
+ this.executor = executor;
+ converterExecutor = convertorExecutor;
+ controlServiceRegistration = rpcProviderRegistry.registerRpcImplementations(
+ ImmutableClassToInstanceMap.<Rpc<?, ?>>builder()
+ .put(GetStatisticsWorkMode.class, this::getStatisticsWorkMode)
+ .put(ChangeStatisticsWorkMode.class, this::changeStatisticsWorkMode)
+ .build());