void ensureRequiredZnodesExist ( ZooKeeper zookeeper , String znode ) throws KeeperException , InterruptedException { mkdirp ( zookeeper , znode ) ; createIfNotThere ( zookeeper , QUEUE_NODE ) ; createIfNotThere ( zookeeper , POOL_NODE ) ; }
Make sure the required znodes are present on the quorum .