diff options
author | Jon Marius Venstad <jonmv@users.noreply.github.com> | 2020-01-20 14:57:48 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-01-20 14:57:48 +0100 |
commit | 7de094e4d19a32a6d443336caa6c70e2a958c2c7 (patch) | |
tree | c2f2439c1d237fcde7bcb22357446876978ff5b2 /zkfacade | |
parent | 60b6253e5096eef77bad716b8f1f3864fdf46c67 (diff) |
Update Curator.java
Diffstat (limited to 'zkfacade')
-rw-r--r-- | zkfacade/src/main/java/com/yahoo/vespa/curator/Curator.java | 5 |
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; |