private void processSync() throws ReplicatorException, IOException, InterruptedException {
  Collection<LogFile> logFiles=logFileMap.values();
  for (  LogFile logFile : logFiles) {
    logFile.flush();
  }
}

private void processSync ( ) throws ReplicatorException , IOException , InterruptedException { Collection < LogFile > logFiles = logFileMap . values ( ) ; for ( LogFile logFile : logFiles ) { logFile . flush ( ) ; } }
issue a synchronization call .
