diff --git a/hibernate-core/src/main/java/org/hibernate/internal/SessionImpl.java b/hibernate-core/src/main/java/org/hibernate/internal/SessionImpl.java index 6d0a6dc53cbf..8813d06edec7 100644 --- a/hibernate-core/src/main/java/org/hibernate/internal/SessionImpl.java +++ b/hibernate-core/src/main/java/org/hibernate/internal/SessionImpl.java @@ -281,17 +281,10 @@ public void afterBegin(TransactionImplementor transaction) { @Override public void beforeCompletion(TransactionImplementor transaction) { - if ( isOpen() ) { - if ( flushBeforeCompletionEnabled ){ - SessionImpl.this.managedFlush(); - } - getActionQueue().beforeTransactionCompletion(); - } - else { - if (actionQueue.hasAfterTransactionActions()){ - LOG.log( Logger.Level.DEBUG, "Session had after transaction actions that were not processed"); - } + if ( isOpen() && flushBeforeCompletionEnabled ) { + SessionImpl.this.managedFlush(); } + beforeTransactionCompletion( transaction ); } @Override