@Test public void assertStop() { regCenter.addCacheData(CloudJobConfigurationNode.ROOT); ReflectionUtils.setFieldValue(cloudJobConfigurationListener, "regCenter", regCenter); cloudJobConfigurationListener.stop(); }
public void stop() { getCache().listenable().removeListener(this); }
CloudJobConfigurationListener implements CuratorCacheListener { public void stop() { getCache().listenable().removeListener(this); } }
CloudJobConfigurationListener implements CuratorCacheListener { public void stop() { getCache().listenable().removeListener(this); } CloudJobConfigurationListener(final CoordinatorRegistryCenter regCenter, final ProducerManager producerManager); }
CloudJobConfigurationListener implements CuratorCacheListener { public void stop() { getCache().listenable().removeListener(this); } CloudJobConfigurationListener(final CoordinatorRegistryCenter regCenter, final ProducerManager producerManager); @Override void event(final Type type, final ChildData oldData, final ChildData data); void start(); void stop(); }
CloudJobConfigurationListener implements CuratorCacheListener { public void stop() { getCache().listenable().removeListener(this); } CloudJobConfigurationListener(final CoordinatorRegistryCenter regCenter, final ProducerManager producerManager); @Override void event(final Type type, final ChildData oldData, final ChildData data); void start(); void stop();  }