diff --git a/dubbo-registry/dubbo-registry-zookeeper/src/main/java/org/apache/dubbo/registry/zookeeper/ZookeeperServiceDiscovery.java b/dubbo-registry/dubbo-registry-zookeeper/src/main/java/org/apache/dubbo/registry/zookeeper/ZookeeperServiceDiscovery.java index c2bfb35e99..dc696db46d 100644 --- a/dubbo-registry/dubbo-registry-zookeeper/src/main/java/org/apache/dubbo/registry/zookeeper/ZookeeperServiceDiscovery.java +++ b/dubbo-registry/dubbo-registry-zookeeper/src/main/java/org/apache/dubbo/registry/zookeeper/ZookeeperServiceDiscovery.java @@ -108,7 +108,7 @@ public class ZookeeperServiceDiscovery extends AbstractServiceDiscovery { @Override public void doUnregister(ServiceInstance serviceInstance) throws RuntimeException { doInServiceRegistry(serviceDiscovery -> serviceDiscovery.unregisterService(build(serviceInstance))); - }; + } @Override @@ -171,7 +171,7 @@ public class ZookeeperServiceDiscovery extends AbstractServiceDiscovery { @Override public void addServiceInstancesChangedListener(ServiceInstancesChangedListener listener) - throws NullPointerException, IllegalArgumentException { + throws NullPointerException, IllegalArgumentException { listener.getServiceNames().forEach(serviceName -> registerServiceWatcher(serviceName, listener)); } @@ -195,7 +195,7 @@ public class ZookeeperServiceDiscovery extends AbstractServiceDiscovery { } protected void registerServiceWatcher(String serviceName, ServiceInstancesChangedListener listener) { - String path = buildServicePath(serviceName); + String path = buildServicePath(serviceName); try { curatorFramework.create().creatingParentsIfNeeded().forPath(path); } catch (KeeperException.NodeExistsException e) {