code: public synchronized void         setBarrier() throws Exception
      {
          try
          {
              client.create().creatingParentContainersIfNeeded().forPath(barrierPath);
          }
          catch ( KeeperException.NodeExistsException ignore )
          {
              // ignore
          }
      }
docs: Utility to set the barrier node
  
  @throws Exception errors