FacadeService { public void enableJob(final String jobName) { disableJobService.remove(jobName); } FacadeService(final CoordinatorRegistryCenter regCenter); void start(); Collection<JobContext> getEligibleJobContext(); void removeLaunchTasksFromQueue(final List<TaskContext> taskContexts); void addRunning(final TaskContext taskContext); void updateDaemonStatus(final TaskContext taskContext, final boolean isIdle); void removeRunning(final TaskContext taskContext); void recordFailoverTask(final TaskContext taskContext); void addTransient(final String jobName); Optional<CloudJobConfigurationPOJO> load(final String jobName); Optional<CloudAppConfigurationPOJO> loadAppConfig(final String appName); Optional<String> getFailoverTaskId(final MetaInfo metaInfo); void addDaemonJobToReadyQueue(final String jobName); boolean isRunning(final TaskContext taskContext); void addMapping(final String taskId, final String hostname); String popMapping(final String taskId); Map<String, Integer> getAllReadyTasks(); Map<String, Set<TaskContext>> getAllRunningTasks(); Map<String, Collection<FailoverTaskInfo>> getAllFailoverTasks(); boolean isJobDisabled(final String jobName); void enableJob(final String jobName); void disableJob(final String jobName); Collection<ExecutorStateInfo> loadExecutorInfo(); void stop();  }
@Test public void assertEnableJob() { facadeService.enableJob("test_job"); verify(disableJobService).remove("test_job"); }