diff options
author | Harald Musum <musum@verizonmedia.com> | 2019-12-04 09:11:10 +0100 |
---|---|---|
committer | Harald Musum <musum@verizonmedia.com> | 2019-12-04 09:11:10 +0100 |
commit | a6f9f158ca8914d968de45d39599324e5a171c3c (patch) | |
tree | 610ea44fac6465d4987a4e2795247f80e3f2078e /zkfacade/src | |
parent | 648a31c9103a0871993ef88cf17052425712e2f1 (diff) |
Prepare for supporting zokeeper client config file
Diffstat (limited to 'zkfacade/src')
-rw-r--r-- | zkfacade/src/main/java/com/yahoo/vespa/curator/Curator.java | 15 |
1 files changed, 8 insertions, 7 deletions
diff --git a/zkfacade/src/main/java/com/yahoo/vespa/curator/Curator.java b/zkfacade/src/main/java/com/yahoo/vespa/curator/Curator.java index 0e20710298f..b76bad5b97b 100644 --- a/zkfacade/src/main/java/com/yahoo/vespa/curator/Curator.java +++ b/zkfacade/src/main/java/com/yahoo/vespa/curator/Curator.java @@ -18,12 +18,11 @@ import org.apache.curator.framework.recipes.cache.NodeCacheListener; import org.apache.curator.framework.recipes.cache.PathChildrenCacheListener; import org.apache.curator.framework.recipes.locks.InterProcessLock; import org.apache.curator.framework.recipes.locks.InterProcessMutex; -import org.apache.curator.framework.state.ConnectionState; -import org.apache.curator.framework.state.ConnectionStateListener; import org.apache.curator.retry.ExponentialBackoffRetry; import org.apache.zookeeper.KeeperException; import org.apache.zookeeper.data.Stat; +import java.io.File; import java.time.Duration; import java.util.Arrays; import java.util.List; @@ -59,6 +58,11 @@ public class Curator implements AutoCloseable { /** Creates a curator instance from a comma-separated string of ZooKeeper host:port strings */ public static Curator create(String connectionSpec) { + return Curator.create(connectionSpec, Optional.empty()); + } + + /** Creates a curator instance from a comma-separated string of ZooKeeper host:port strings */ + public static Curator create(String connectionSpec, Optional<File> clientConfigFile) { return new Curator(connectionSpec, connectionSpec); } @@ -174,11 +178,8 @@ public class Curator implements AutoCloseable { // To avoid getting warning in log, see ticket 6389740 private void addFakeListener() { - curatorFramework.getConnectionStateListenable().addListener(new ConnectionStateListener() { - @Override - public void stateChanged(CuratorFramework curatorFramework, ConnectionState connectionState) { - // empty, not needed now - } + curatorFramework.getConnectionStateListenable().addListener((curatorFramework, connectionState) -> { + // empty, not needed now }); } |