GuaranteeListenerManager extends AbstractListenerManager { @Override public void start() { addDataListener(new StartedNodeRemovedJobListener()); addDataListener(new CompletedNodeRemovedJobListener()); } GuaranteeListenerManager(final CoordinatorRegistryCenter coordinatorRegistryCenter, final JobConfiguration jobConfiguration, final List<ElasticJobListener> elasticJobListeners); @Override void start();  }
@Test public void assertStart() { guaranteeListenerManager.start(); verify(jobNodeStorage, times(2)).addDataListener(Matchers.<AbstractJobListener>any()); }