ShutdownListenerManager extends AbstractListenerManager { @Override public void start() { addDataListener(new InstanceShutdownStatusJobListener()); } ShutdownListenerManager(final CoordinatorRegistryCenter regCenter, final String jobName); @Override void start();  }
@Test public void assertStart() { shutdownListenerManager.start(); verify(jobNodeStorage).addDataListener(ArgumentMatchers.any()); }