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