private synchronized void createQueueBranch(final QueueInfo queueInfo) throws Exception {
  final File queueDir=new File(providerDirPath);
  File lockFile=new File(AsyncDBUtil.getGlobalLockFilePath());
  LOG.info("Creating directory for provider {} ({})",queueInfo.getName(),providerDirPath);
  if (!lockFile.exists()) {
    FileUtils.touch(lockFile);
  }
  if (!queueDir.exists()) {
    Callable<Object> queueDirCreationTask=null;
    AsyncDBUtil.performLocked(queueDirCreationTask,AsyncDBUtil.getGlobalLockFilePath(),this);
  }
}

private synchronized void createQueueBranch ( final QueueInfo queueInfo ) throws Exception { final File queueDir = new File ( providerDirPath ) ; File lockFile = new File ( AsyncDBUtil . getGlobalLockFilePath ( ) ) ; LOG . info ( "Creating directory for provider {} ({})" , queueInfo . getName ( ) , providerDirPath ) ; if ( ! lockFile . exists ( ) ) { FileUtils . touch ( lockFile ) ; } if ( ! queueDir . exists ( ) ) { Callable < Object > queueDirCreationTask = null ; AsyncDBUtil . performLocked ( queueDirCreationTask , AsyncDBUtil . getGlobalLockFilePath ( ) , this ) ; } }
creates queue branch with metainfo directory in the filesystem .
