Throw SQLException if enlistResource returns false

agroal · Oct 18, 2023 · ced9e8b · ced9e8b
1 parent 707aa09
commit ced9e8b
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/agroal-narayana/src/main/java/io/agroal/narayana/NarayanaTransactionIntegration.java b/agroal-narayana/src/main/java/io/agroal/narayana/NarayanaTransactionIntegration.java
@@ -118,7 +118,9 @@ public void associate(TransactionAware transactionAware, XAResource xaResource)
                 if ( transactionSynchronizationRegistry.getResource( key ) == null ) {
                     transactionSynchronizationRegistry.registerInterposedSynchronization( new InterposedSynchronization( transactionAware ) );
                     transactionSynchronizationRegistry.putResource( key, transactionAware );
-                    transactionManager.getTransaction().enlistResource( createXaResource( transactionAware, xaResource ) );
+                    if ( !transactionManager.getTransaction().enlistResource( createXaResource( transactionAware, xaResource ) ) ) {
+                        throw new SQLException("Unable to enlist connection to existing transaction");
+                    }
                 } else {
                     transactionAware.transactionStart();
                 }