This is an automated email from the ASF dual-hosted git repository.
amichair pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/aries-rsa.git
The following commit(s) were added to refs/heads/master by this push:
new f1c8ae8a ARIES-2237 Fix ZookeeperEndpointRepository propagating
exception when removing node
f1c8ae8a is described below
commit f1c8ae8a57fe0e53b1cfb90e68e495759d1429b4
Author: Amichai Rothman <[email protected]>
AuthorDate: Sun Jun 7 19:43:41 2026 +0300
ARIES-2237 Fix ZookeeperEndpointRepository propagating exception when
removing node
---
.../rsa/discovery/zookeeper/client/ZookeeperEndpointRepository.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
diff --git
a/discovery/zookeeper/src/main/java/org/apache/aries/rsa/discovery/zookeeper/client/ZookeeperEndpointRepository.java
b/discovery/zookeeper/src/main/java/org/apache/aries/rsa/discovery/zookeeper/client/ZookeeperEndpointRepository.java
index 7349ece1..9f386e25 100644
---
a/discovery/zookeeper/src/main/java/org/apache/aries/rsa/discovery/zookeeper/client/ZookeeperEndpointRepository.java
+++
b/discovery/zookeeper/src/main/java/org/apache/aries/rsa/discovery/zookeeper/client/ZookeeperEndpointRepository.java
@@ -128,7 +128,11 @@ public class ZookeeperEndpointRepository {
private void remove(EndpointDescription endpoint) throws KeeperException,
InterruptedException {
String path = getZooKeeperPath(endpoint.getId());
LOG.info("Removing endpoint in zookeeper. Endpoint: {}, Path: {}",
endpoint, path);
- zk.delete(path, -1);
+ try {
+ zk.delete(path, -1);
+ } catch (NoNodeException nne) {
+ // ignore - we wanted it deleted and it already is
+ }
}
private boolean notEmpty(String part) {