summaryrefslogtreecommitdiffstats
path: root/zkfacade
diff options
context:
space:
mode:
authorJon Marius Venstad <jonmv@users.noreply.github.com>2020-01-20 14:57:48 +0100
committerGitHub <noreply@github.com>2020-01-20 14:57:48 +0100
commit7de094e4d19a32a6d443336caa6c70e2a958c2c7 (patch)
treec2f2439c1d237fcde7bcb22357446876978ff5b2 /zkfacade
parent60b6253e5096eef77bad716b8f1f3864fdf46c67 (diff)
Update Curator.java
Diffstat (limited to 'zkfacade')
-rw-r--r--zkfacade/src/main/java/com/yahoo/vespa/curator/Curator.java5
1 files changed, 2 insertions, 3 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 d1246699ebc..7c5b1ae319a 100644
--- a/zkfacade/src/main/java/com/yahoo/vespa/curator/Curator.java
+++ b/zkfacade/src/main/java/com/yahoo/vespa/curator/Curator.java
@@ -118,7 +118,7 @@ public class Curator implements AutoCloseable {
if (this.curatorFramework != null) {
validateConnectionSpec(connectionSpec);
validateConnectionSpec(zooKeeperEnsembleConnectionSpec);
- addFakeListener();
+ addLoggingListener();
curatorFramework.start();
}
@@ -201,8 +201,7 @@ public class Curator implements AutoCloseable {
return new InterProcessMutex(curatorFramework, lockPath);
}
- // To avoid getting warning in log, see ticket 6389740
- private void addFakeListener() {
+ private void addLoggingListener() {
curatorFramework.getConnectionStateListenable().addListener((curatorFramework, connectionState) -> {
switch (connectionState) {
case SUSPENDED: logger.info("ZK connection state change: SUSPENDED"); break;