ZKLogMetadataStore implements LogMetadataStore { @Override public Future<URI> createLog(String logName) { return Future.value(namespace); } ZKLogMetadataStore(
            DistributedLogConfiguration conf,
            URI namespace,
            ZooKeeperClient zkc,
            OrderedScheduler scheduler); @Override Future<URI> createLog(String logName); @Override Future<Optional<URI>> getLogLocation(String logName); @Override Future<Iterator<String>> getLogs(); @Override void registerNamespaceListener(NamespaceListener listener);  }
@Test(timeout = 60000) public void testCreateLog() throws Exception { assertEquals(uri, FutureUtils.result(metadataStore.createLog("test"))); }