@Override
  public void flush() throws InterruptedException {
    FlushToken token = new FlushToken();
    edges.add(token);
    token.cdl.await();
  }
Should be invoked when GemFire cache is closing or closed.
geode-core/src/main/java/org/apache/geode/internal/sequencelog/SequenceLoggerImpl.java