DefaultMetaChangeManager implements MetaChangeManager { @Override public void start() { int interval = consoleConfig.getRedisReplicationHealthCheckInterval(); future = scheduled.scheduleWithFixedDelay(new AbstractExceptionLogTask() { @Override protected void doRun() throws Exception { checkDcMetaChange(); } }, interval * 2, interval, TimeUnit.MILLISECONDS); }  @Override void start(); @Override void stop(); @Override DcMetaChangeManager getOrCreate(String dcId); @Override void ignore(String dcId); @Override void startIfPossible(String dcId);  }
@Test public void testStart() { metaChangeManager.start(); }