question: public synchronized void connect ( ) { if ( ! _zkConnection . isStarted ( ) ) { _zkConnection . start ( ) ; } if ( StringUtils . isEmpty ( siteId ) ) { generateSiteId ( ) ; } }
target:  Connect to ZK cluster. As long quorum of nodes are available, client can talk to a cluster. If connection drop, this implementation will continuously retry sleeping 5 seconds in between.