@Test(expectedExceptions = IllegalStateException.class) public void testResolveUrlBeforeUpdateServiceUrl() throws Exception { resolver.resolveHostUri(); }
@Override public URI resolveHostUri() { InetSocketAddress host = resolveHost(); String hostUrl = serviceUri.getServiceScheme() + ": return URI.create(hostUrl); }
PulsarServiceNameResolver implements ServiceNameResolver { @Override public URI resolveHostUri() { InetSocketAddress host = resolveHost(); String hostUrl = serviceUri.getServiceScheme() + ": return URI.create(hostUrl); } }
PulsarServiceNameResolver implements ServiceNameResolver { @Override public URI resolveHostUri() { InetSocketAddress host = resolveHost(); String hostUrl = serviceUri.getServiceScheme() + ": return URI.create(hostUrl); }  }
PulsarServiceNameResolver implements ServiceNameResolver { @Override public URI resolveHostUri() { InetSocketAddress host = resolveHost(); String hostUrl = serviceUri.getServiceScheme() + ": return URI.create(hostUrl); }  @Override InetSocketAddress resolveHost(); @Override URI resolveHostUri(); @Override String getServiceUrl(); @Override ServiceURI getServiceUri(); @Override void updateServiceUrl(String serviceUrl); }
PulsarServiceNameResolver implements ServiceNameResolver { @Override public URI resolveHostUri() { InetSocketAddress host = resolveHost(); String hostUrl = serviceUri.getServiceScheme() + ": return URI.create(hostUrl); }  @Override InetSocketAddress resolveHost(); @Override URI resolveHostUri(); @Override String getServiceUrl(); @Override ServiceURI getServiceUri(); @Override void updateServiceUrl(String serviceUrl);  }