ShardingListenerManager extends AbstractListenerManager { @Override public void start() { addDataListener(new ShardingTotalCountChangedJobListener()); addDataListener(new ListenServersChangedJobListener()); } ShardingListenerManager(final CoordinatorRegistryCenter coordinatorRegistryCenter, final JobConfiguration jobConfiguration); @Override void start();  }
@Test public void assertStart() { shardingListenerManager.start(); verify(jobNodeStorage, times(2)).addDataListener(Matchers.<AbstractJobListener>any()); }