diff options
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; |