FailoverListenerManager extends AbstractListenerManager { @Override public void start() { addDataListener(new JobCrashedJobListener()); addDataListener(new FailoverSettingsChangedJobListener()); } FailoverListenerManager(final CoordinatorRegistryCenter regCenter, final String jobName); @Override void start();  }
@Test public void assertStart() { failoverListenerManager.start(); verify(jobNodeStorage, times(2)).addDataListener(ArgumentMatchers.<AbstractJobListener>any()); }