class PersistentMessageBuffer implements MessageBuffer {

    @Override
    public synchronized void sync() throws IOException {
        if (current != null) {
            current.checkpoint(true);
        }
    }

    public  PersistentMessageBuffer(File dir);

}