219220221222223224225226227228229
{ try { SynchronizationBarrier barrier = new SynchronizationBarrier(); journal.commit(barrier); barrier.waitFor(); } catch (InterruptedException e) { throw new DataStoreException("Wait for commit barrier was interrupted"); }
428429430431432433434435436437438
commitable.commitChanges(commitBarrier); } try { commitBarrier.waitFor(); } catch (InterruptedException e) { throw new JMSException("Commit barrier was interrupted"); }