@Test public void assertStart() { setReconcileEnabled(true); schedulerService.start(); InOrder inOrder = getInOrder(); inOrder.verify(facadeService).start(); inOrder.verify(producerManager).startup(); inOrder.verify(statisticManager).startup(); inOrder.verify(cloudJobConfigurationListener).start(); inOrder.verify(taskLaunchScheduledService).startAsync(); inOrder.verify(consoleBootstrap).start(); inOrder.verify(schedulerDriver).start(); inOrder.verify(reconcileService).startAsync(); }
public void start() { facadeService.start(); producerManager.startup(); statisticManager.startup(); cloudJobConfigurationListener.start(); cloudAppConfigurationListener.start(); cloudJobDisableListener.start(); cloudAppDisableListener.start(); taskLaunchScheduledService.startAsync(); consoleBootstrap.start(); schedulerDriver.start(); if (env.getFrameworkConfiguration().isEnabledReconcile()) { reconcileService.startAsync(); } }
SchedulerService { public void start() { facadeService.start(); producerManager.startup(); statisticManager.startup(); cloudJobConfigurationListener.start(); cloudAppConfigurationListener.start(); cloudJobDisableListener.start(); cloudAppDisableListener.start(); taskLaunchScheduledService.startAsync(); consoleBootstrap.start(); schedulerDriver.start(); if (env.getFrameworkConfiguration().isEnabledReconcile()) { reconcileService.startAsync(); } } }
SchedulerService { public void start() { facadeService.start(); producerManager.startup(); statisticManager.startup(); cloudJobConfigurationListener.start(); cloudAppConfigurationListener.start(); cloudJobDisableListener.start(); cloudAppDisableListener.start(); taskLaunchScheduledService.startAsync(); consoleBootstrap.start(); schedulerDriver.start(); if (env.getFrameworkConfiguration().isEnabledReconcile()) { reconcileService.startAsync(); } } SchedulerService(final CoordinatorRegistryCenter regCenter); }
SchedulerService { public void start() { facadeService.start(); producerManager.startup(); statisticManager.startup(); cloudJobConfigurationListener.start(); cloudAppConfigurationListener.start(); cloudJobDisableListener.start(); cloudAppDisableListener.start(); taskLaunchScheduledService.startAsync(); consoleBootstrap.start(); schedulerDriver.start(); if (env.getFrameworkConfiguration().isEnabledReconcile()) { reconcileService.startAsync(); } } SchedulerService(final CoordinatorRegistryCenter regCenter); void start(); void stop(); }
SchedulerService { public void start() { facadeService.start(); producerManager.startup(); statisticManager.startup(); cloudJobConfigurationListener.start(); cloudAppConfigurationListener.start(); cloudJobDisableListener.start(); cloudAppDisableListener.start(); taskLaunchScheduledService.startAsync(); consoleBootstrap.start(); schedulerDriver.start(); if (env.getFrameworkConfiguration().isEnabledReconcile()) { reconcileService.startAsync(); } } SchedulerService(final CoordinatorRegistryCenter regCenter); void start(); void stop();  }