CloudJobConfigurationService { public void add(final CloudJobConfigurationPOJO cloudJobConfig) { regCenter.persist( CloudJobConfigurationNode.getRootNodePath(cloudJobConfig.getJobName()), YamlEngine.marshal(cloudJobConfig)); }  void add(final CloudJobConfigurationPOJO cloudJobConfig); void update(final CloudJobConfigurationPOJO cloudJobConfig); Collection<CloudJobConfigurationPOJO> loadAll(); Optional<CloudJobConfigurationPOJO> load(final String jobName); void remove(final String jobName);  }
@Test public void assertAdd() { CloudJobConfigurationPOJO cloudJobConfig = CloudJobConfigurationBuilder.createCloudJobConfiguration("test_job"); configService.add(cloudJobConfig); verify(regCenter).persist("/config/job/test_job", YAML); }