CloudJobConfigurationListener implements CuratorCacheListener { public void start() { getCache().listenable().addListener(this, Executors.newSingleThreadExecutor()); } CloudJobConfigurationListener(final CoordinatorRegistryCenter regCenter, final ProducerManager producerManager); @Override void event(final Type type, final ChildData oldData, final ChildData data); void start(); void stop();  }
@Test public void assertStart() { cloudJobConfigurationListener.start(); }