ClusterControllerConfigFetcher { public boolean updated(long timeoutMillis) throws Exception { if (configUpdated(timeoutMillis)) { log.fine("Updated fleetcontroller config."); options = generateOptions(); return true; } else { return false; } } ClusterControllerConfigFetcher(); void close(); FleetControllerOptions getOptions(); FleetControllerOptions generateOptions(); boolean updated(long timeoutMillis); long getGeneration();  }
@Test public void testConfigUpdate() throws Exception { setFleetControllerConfigProperty(); setSlobrokConfigProperty(); addFleetControllerConfig(2, 1); addSlobrokConfig(); addDistributionConfig(); addZookeepersConfig(); ClusterControllerConfigFetcher configFetcher = new ClusterControllerConfigFetcher() { boolean configUpdated(long millis) { return true; } }; configFetcher.updated(1000); }