PollingZooKeeperConfigurationProvider extends
    AbstractZooKeeperConfigurationProvider implements LifecycleAware { @Override protected FlumeConfiguration getFlumeConfiguration() { return flumeConfiguration; } PollingZooKeeperConfigurationProvider(String agentName,
      String zkConnString, String basePath, EventBus eventBus); @Override void start(); @Override void stop(); @Override LifecycleState getLifecycleState();  }
@Test public void testPolling() throws Exception { es.awaitEvent(); es.reset(); FlumeConfiguration fc = cp.getFlumeConfiguration(); Assert.assertTrue(fc.getConfigurationErrors().isEmpty()); AgentConfiguration ac = fc.getConfigurationFor(AGENT_NAME); Assert.assertNull(ac); addData(); es.awaitEvent(); es.reset(); verifyProperties(cp); }