Repository: curator Updated Branches: refs/heads/CURATOR-176 [created] 37dc44785
updateService() doesn't need to validate the service exists in the local services cache Project: http://git-wip-us.apache.org/repos/asf/curator/repo Commit: http://git-wip-us.apache.org/repos/asf/curator/commit/742e0927 Tree: http://git-wip-us.apache.org/repos/asf/curator/tree/742e0927 Diff: http://git-wip-us.apache.org/repos/asf/curator/diff/742e0927 Branch: refs/heads/CURATOR-176 Commit: 742e092756722f34276d55cfb139d20aa681b908 Parents: 3eea676 Author: randgalt <[email protected]> Authored: Tue Dec 30 14:26:46 2014 -0500 Committer: randgalt <[email protected]> Committed: Tue Dec 30 14:26:46 2014 -0500 ---------------------------------------------------------------------- .../apache/curator/x/discovery/details/ServiceDiscoveryImpl.java | 2 -- 1 file changed, 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/curator/blob/742e0927/curator-x-discovery/src/main/java/org/apache/curator/x/discovery/details/ServiceDiscoveryImpl.java ---------------------------------------------------------------------- diff --git a/curator-x-discovery/src/main/java/org/apache/curator/x/discovery/details/ServiceDiscoveryImpl.java b/curator-x-discovery/src/main/java/org/apache/curator/x/discovery/details/ServiceDiscoveryImpl.java index ad6ce89..a55f678 100644 --- a/curator-x-discovery/src/main/java/org/apache/curator/x/discovery/details/ServiceDiscoveryImpl.java +++ b/curator-x-discovery/src/main/java/org/apache/curator/x/discovery/details/ServiceDiscoveryImpl.java @@ -173,8 +173,6 @@ public class ServiceDiscoveryImpl<T> implements ServiceDiscovery<T> @Override public void updateService(ServiceInstance<T> service) throws Exception { - Preconditions.checkArgument(services.containsKey(service.getId()), "Service is not registered: " + service); - byte[] bytes = serializer.serialize(service); String path = pathForInstance(service.getName(), service.getId()); client.setData().forPath(path, bytes);
