public Long getPrimarySsId ( String address , boolean sync ) throws IOException , KeeperException , InterruptedException , ClassNotFoundException { Stat stat = new Stat ( ) ; String node = getSsIdNode ( address ) ; byte [ ] data = getNodeData ( node , stat , false , sync ) ; if ( data == null ) { return null ; } return ( Long ) SerializableUtils . getFromBytes ( data , Long . class ) ; }
Retrieves the current session id for the cluster from zookeeper .