@Override public void transactionCommited(final long commitTime){
  if (listeners.isEmpty()) {
    records.reset();
  }
 else {
    records.flush();
    listeners.forEach(null);
  }
}

@ Override public void transactionCommited ( final long commitTime ) { if ( listeners . isEmpty ( ) ) { records . reset ( ) ; } else { records . flush ( ) ; listeners . forEach ( null ) ; } }
notification of transaction committed .
