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