@Test
public void testDiscover()
{

  ZKAssistedDiscovery discovery = new ZKAssistedDiscovery();
  discovery.setServiceName("ApexFlumeTest");
  discovery.setConnectionString("localhost:2181");
  discovery.setBasePath("/HelloApex");
  discovery.setup(null);
  assertNotNull("Discovered Sinks", discovery.discover());
  discovery.teardown();
}