FailoverListenerManager extends AbstractListenerManager { @Override public void start() { addDataListener(new JobCrashedJobListener()); addDataListener(new FailoverJobCrashedJobListener()); addDataListener(new FailoverSettingsChangedJobListener()); } FailoverListenerManager(final CoordinatorRegistryCenter coordinatorRegistryCenter, final JobConfiguration jobConfiguration); @Override void start();  }
@Test public void assertStart() { failoverListenerManager.start(); verify(jobNodeStorage, times(3)).addDataListener(Matchers.<AbstractJobListener>any()); }