Re-throw JTA related exceptions (Issue #30)

AxonFramework · Jun 28, 2021 · 831220e · 831220e
1 parent 4702cf8
commit 831220e
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 5 deletions.
diff --git a/cdi/src/main/java/org/axonframework/extensions/cdi/transaction/JtaTransaction.java b/cdi/src/main/java/org/axonframework/extensions/cdi/transaction/JtaTransaction.java
@@ -61,8 +61,7 @@ private void detectContext() {
                     owned = false;
                 }
             } catch (SystemException ex) {
-                logger.warn("Had trouble trying to get BMT transaction status.", ex);
-                owned = false;
+                throw new JtaTransactionException("Had trouble trying to get BMT transaction status.", ex);
             }
         } else {
             registry = getTransactionSynchronizationRegistry();
@@ -87,7 +86,7 @@ private void attemptBegin() {
                     logger.debug("Did not try to begin non-owned BMT transaction.");
                 }
             } catch (SystemException | NotSupportedException ex) {
-                logger.warn("Had trouble trying to start BMT transaction.", ex);
+                throw new JtaTransactionException("Had trouble trying to start BMT transaction.", ex);
             }
         } else {
             if (registry != null) {
@@ -118,7 +117,7 @@ private void attemptCommit() {
             } catch (SystemException | RollbackException
                     | HeuristicMixedException | HeuristicRollbackException
                     | SecurityException | IllegalStateException ex) {
-                logger.warn("Had trouble trying to commit BMT transaction.", ex);
+                throw new JtaTransactionException("Had trouble trying to commit BMT transaction.", ex);
             }
         } else {
             if (registry != null) {
@@ -148,7 +147,7 @@ private void attemptRollback() {
                             statusToString(userTransaction.getStatus()));
                 }
             } catch (SystemException | SecurityException | IllegalStateException ex) {
-                logger.warn("Had trouble trying to roll back BMT transaction.", ex);
+                throw new JtaTransactionException("Had trouble trying to roll back BMT transaction.", ex);
             }
         } else {
             if (registry != null) {

diff --git a/cdi/src/main/java/org/axonframework/extensions/cdi/transaction/JtaTransactionException.java b/cdi/src/main/java/org/axonframework/extensions/cdi/transaction/JtaTransactionException.java
@@ -0,0 +1,15 @@
+package org.axonframework.extensions.cdi.transaction;
+
+import org.axonframework.common.AxonException;
+
+public class JtaTransactionException extends AxonException {
+
+
+    public JtaTransactionException(String message) {
+        super(message);
+    }
+
+    public JtaTransactionException(String message, Throwable cause) {
+        super(message, cause);
+    }
+}