@Test public void testMediumPayloadSize() { int padding = ServiceEndPointJsonCodec.toJson(FOO).getBytes(Charsets.UTF_8).length; String payload = Strings.repeat("x", MAX_DATA_SIZE - padding - 1); _registry.register(newEndPoint(FOO.getServiceName(), FOO.getId(), payload), false); }
@Override public void register(ServiceEndPoint endPoint) { register(endPoint, true); }
ZooKeeperServiceRegistry implements ServiceRegistry { @Override public void register(ServiceEndPoint endPoint) { register(endPoint, true); } }
ZooKeeperServiceRegistry implements ServiceRegistry { @Override public void register(ServiceEndPoint endPoint) { register(endPoint, true); } ZooKeeperServiceRegistry(CuratorFramework curator, MetricRegistry metrics); @VisibleForTesting  ZooKeeperServiceRegistry(NodeFactory nodeFactory, MetricRegistry metrics); }
ZooKeeperServiceRegistry implements ServiceRegistry { @Override public void register(ServiceEndPoint endPoint) { register(endPoint, true); } ZooKeeperServiceRegistry(CuratorFramework curator, MetricRegistry metrics); @VisibleForTesting  ZooKeeperServiceRegistry(NodeFactory nodeFactory, MetricRegistry metrics); @Override void register(ServiceEndPoint endPoint); @Override void unregister(ServiceEndPoint endPoint); @Override synchronized void close(); static String makeServicePath(String serviceName); }
ZooKeeperServiceRegistry implements ServiceRegistry { @Override public void register(ServiceEndPoint endPoint) { register(endPoint, true); } ZooKeeperServiceRegistry(CuratorFramework curator, MetricRegistry metrics); @VisibleForTesting  ZooKeeperServiceRegistry(NodeFactory nodeFactory, MetricRegistry metrics); @Override void register(ServiceEndPoint endPoint); @Override void unregister(ServiceEndPoint endPoint); @Override synchronized void close(); static String makeServicePath(String serviceName);  }