diff --git a/src/main/java/io/ebeaninternal/api/SpiTransactionManager.java b/src/main/java/io/ebeaninternal/api/SpiTransactionManager.java index d2c23ee67..1b6ae2894 100644 --- a/src/main/java/io/ebeaninternal/api/SpiTransactionManager.java +++ b/src/main/java/io/ebeaninternal/api/SpiTransactionManager.java @@ -40,4 +40,19 @@ public interface SpiTransactionManager { */ void externalRemoveTransaction(); + /** + * Notify of a transaction commit. + */ + void notifyOfCommit(SpiTransaction transaction); + + /** + * Notify of a transaction rollback. + */ + void notifyOfRollback(SpiTransaction transaction, Throwable cause); + + /** + * Notify of a query only transaction commit. + */ + void notifyOfQueryOnly(SpiTransaction transaction); + } diff --git a/src/main/java/io/ebeaninternal/server/transaction/TransactionManager.java b/src/main/java/io/ebeaninternal/server/transaction/TransactionManager.java index 8b5c87671..396159846 100644 --- a/src/main/java/io/ebeaninternal/server/transaction/TransactionManager.java +++ b/src/main/java/io/ebeaninternal/server/transaction/TransactionManager.java @@ -360,7 +360,8 @@ public class TransactionManager implements SpiTransactionManager { /** * Process a local rolled back transaction. */ - void notifyOfRollback(SpiTransaction transaction, Throwable cause) { + @Override + public void notifyOfRollback(SpiTransaction transaction, Throwable cause) { try { if (txnLogger.isDebug()) { @@ -379,8 +380,8 @@ public class TransactionManager implements SpiTransactionManager { /** * Query only transaction in read committed isolation. */ - void notifyOfQueryOnly(SpiTransaction transaction) { - + @Override + public void notifyOfQueryOnly(SpiTransaction transaction) { // Nothing that interesting here if (txnLogger.isTrace()) { txnLogger.trace(transaction.getLogPrefix() + "Commit - query only"); @@ -414,8 +415,8 @@ public class TransactionManager implements SpiTransactionManager { /** * Process a local committed transaction. */ - void notifyOfCommit(SpiTransaction transaction) { - + @Override + public void notifyOfCommit(SpiTransaction transaction) { try { if (txnLogger.isDebug()) { txnLogger.debug(transaction.getLogPrefix() + "Commit");