ZookeeperClient implements Watcher { public void close() { if (PINGER_ENABLED) { ZkPinger pinger0 = pinger; if (pinger0 != null) pinger0.stop(); } closeClient(); } ZookeeperClient(IgniteLogger log, String connectString, int sesTimeout, IgniteRunnable connLostC);   ZookeeperClient(String igniteInstanceName,
        IgniteLogger log,
        String connectString,
        int sesTimeout,
        IgniteRunnable connLostC); @Override void process(WatchedEvent evt); void close();  }
@Test public void testClose() throws Exception { startZK(1); final ZookeeperClient client = createClient(SES_TIMEOUT); client.createIfNeeded("/apacheIgnite1", null, CreateMode.PERSISTENT); client.zk().close(); GridTestUtils.assertThrows(log, new Callable<Void>() { @Override public Void call() throws Exception { client.createIfNeeded("/apacheIgnite2", null, CreateMode.PERSISTENT); return null; } }, ZookeeperClientFailedException.class, null); }