@VisibleForTesting boolean waitForZKConnections(long waitTimeSeconds) {
        for (int i = 0; i < waitTimeSeconds; i++) {
            if (connected) {
                return connected;
            }
            log.debug("Waiting for connect");
            try { Thread.sleep(1000); } catch (InterruptedException ex) {}
        }
        return connected;
    }
@VisibleForTesting boolean waitForZKConnections(long waitTimeSeconds) {
        for (int i = 0; i < waitTimeSeconds; i++) {
            if (connected) {
                return connected;
            }
            log.debug("Waiting for connect");
            try { Thread.sleep(1000); } catch (InterruptedException ex) {}
        }
        return connected;
    }
@ VisibleForTesting boolean waitForZKConnections ( long waitTimeSeconds ) { for ( int i = 0 ; i < waitTimeSeconds ; i ++ ) { if ( connected ) { return connected ; } log . debug ( "Waiting for connect" ) ; try { Thread . sleep ( 1000 ) ; } catch ( InterruptedException ex ) { } } return connected ; }
Waits until the zookeeper connection is available.
@param waitTimeSeconds
Waits until the zookeeper connection is available .