class FlumeEventQueue {

  synchronized void close() throws IOException {
    try {
      if (db != null) {
        db.close();
      }
    } catch (Exception ex) {
      LOG.warn("Error closing db", ex);
    }
    try {
      backingStore.close();
      inflightPuts.close();
      inflightTakes.close();
    } catch (IOException e) {
      LOG.warn("Error closing backing store", e);
    }
  }

    FlumeEventQueue(EventQueueBackingStore backingStore, File inflightTakesFile,
                  File inflightPutsFile, File queueSetDBDir);

}