code: @Override
  	public void commitChanges() throws DataStoreException
      {
      	try
      	{
  	    	SynchronizationBarrier barrier = new SynchronizationBarrier();
  	    	journal.commit(barrier);
  	    	barrier.waitFor();
      	}
      	catch (InterruptedException e)
      	{
      		throw new DataStoreException("Wait for commit barrier was interrupted");
      	}
      }
docs: /* (non-Javadoc)
  @see net.timewalker.ffmq4.storage.data.DataStore#commit()