@Test public void assertGetScriptJobConfig() { when(regCenter.get("/test_job/config")).thenReturn(LifecycleYamlConstants.getScriptJobYaml()); JobConfigurationPOJO actual = jobConfigAPI.getJobConfiguration("test_job"); assertJobConfig(actual); assertThat(actual.getProps().getProperty(ScriptJobProperties.SCRIPT_KEY), is("echo")); verify(regCenter).get("/test_job/config"); }
@Override public JobConfigurationPOJO getJobConfiguration(final String jobName) { return YamlEngine.unmarshal(regCenter.get(new JobNodePath(jobName).getConfigNodePath()), JobConfigurationPOJO.class); }
JobConfigurationAPIImpl implements JobConfigurationAPI { @Override public JobConfigurationPOJO getJobConfiguration(final String jobName) { return YamlEngine.unmarshal(regCenter.get(new JobNodePath(jobName).getConfigNodePath()), JobConfigurationPOJO.class); } }
JobConfigurationAPIImpl implements JobConfigurationAPI { @Override public JobConfigurationPOJO getJobConfiguration(final String jobName) { return YamlEngine.unmarshal(regCenter.get(new JobNodePath(jobName).getConfigNodePath()), JobConfigurationPOJO.class); }  }
JobConfigurationAPIImpl implements JobConfigurationAPI { @Override public JobConfigurationPOJO getJobConfiguration(final String jobName) { return YamlEngine.unmarshal(regCenter.get(new JobNodePath(jobName).getConfigNodePath()), JobConfigurationPOJO.class); }  @Override JobConfigurationPOJO getJobConfiguration(final String jobName); @Override void updateJobConfiguration(final JobConfigurationPOJO jobConfig); @Override void removeJobConfiguration(final String jobName); }
JobConfigurationAPIImpl implements JobConfigurationAPI { @Override public JobConfigurationPOJO getJobConfiguration(final String jobName) { return YamlEngine.unmarshal(regCenter.get(new JobNodePath(jobName).getConfigNodePath()), JobConfigurationPOJO.class); }  @Override JobConfigurationPOJO getJobConfiguration(final String jobName); @Override void updateJobConfiguration(final JobConfigurationPOJO jobConfig); @Override void removeJobConfiguration(final String jobName);  }