public synchronized void connect(){
  if (!_zkConnection.isStarted()) {
    _zkConnection.start();
  }
  if (StringUtils.isEmpty(siteId)) {
    generateSiteId();
  }
}

public synchronized void connect ( ) { if ( ! _zkConnection . isStarted ( ) ) { _zkConnection . start ( ) ; } if ( StringUtils . isEmpty ( siteId ) ) { generateSiteId ( ) ; } }
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 .
