@Test public void testRegister_2_hosts_in_1_site() throws IOException { registryClient.register(SITE_2_HOSTS, new InetSocketAddress(1234), URI.create("http: registryClient.register(SITE_2_HOSTS, new InetSocketAddress(1235), URI.create("http: try { registryClient.register(SITE_2_HOSTS, new InetSocketAddress(1236), URI.create("http: } catch (IOException e) { assertTrue(e.getMessage().matches(".*Unable to register hostId, all hosts are full on site.*")); } }
@Override public String register(String siteId, InetSocketAddress gondolaAddress, URI serviceUri) throws IOException { try { return registerHostIdOnZookeeper(siteId, gondolaAddress); } catch (Exception e) { throw new IOException(e); } }
ZookeeperRegistryClient implements RegistryClient { @Override public String register(String siteId, InetSocketAddress gondolaAddress, URI serviceUri) throws IOException { try { return registerHostIdOnZookeeper(siteId, gondolaAddress); } catch (Exception e) { throw new IOException(e); } } }
ZookeeperRegistryClient implements RegistryClient { @Override public String register(String siteId, InetSocketAddress gondolaAddress, URI serviceUri) throws IOException { try { return registerHostIdOnZookeeper(siteId, gondolaAddress); } catch (Exception e) { throw new IOException(e); } } protected  ZookeeperRegistryClient(CuratorFramework curatorFramework, ObjectMapper objectMapper, Config config); }
ZookeeperRegistryClient implements RegistryClient { @Override public String register(String siteId, InetSocketAddress gondolaAddress, URI serviceUri) throws IOException { try { return registerHostIdOnZookeeper(siteId, gondolaAddress); } catch (Exception e) { throw new IOException(e); } } protected  ZookeeperRegistryClient(CuratorFramework curatorFramework, ObjectMapper objectMapper, Config config); @Override String register(String siteId, InetSocketAddress gondolaAddress, URI serviceUri); @Override void addListener(Consumer<Entry> listener); @Override Map<String, Entry> getEntries(); @Override boolean waitForClusterComplete(int timeoutMs); }
ZookeeperRegistryClient implements RegistryClient { @Override public String register(String siteId, InetSocketAddress gondolaAddress, URI serviceUri) throws IOException { try { return registerHostIdOnZookeeper(siteId, gondolaAddress); } catch (Exception e) { throw new IOException(e); } } protected  ZookeeperRegistryClient(CuratorFramework curatorFramework, ObjectMapper objectMapper, Config config); @Override String register(String siteId, InetSocketAddress gondolaAddress, URI serviceUri); @Override void addListener(Consumer<Entry> listener); @Override Map<String, Entry> getEntries(); @Override boolean waitForClusterComplete(int timeoutMs); static final String GONDOLA_HOSTS; }