Add the JtaRequiresNewController class

Author: nakamura-to

deployment/src/main/java/org/seasar/doma/quarkus/deployment/DomaProcessor.java

@@ -22,6 +22,7 @@
 import org.seasar.doma.DaoImplementation;
 import org.seasar.doma.quarkus.runtime.DomaProducer;
 import org.seasar.doma.quarkus.runtime.DomaRecorder;
+import org.seasar.doma.quarkus.runtime.JtaRequiresNewController;
 import org.seasar.doma.quarkus.runtime.ScriptExecutor;
 
 class DomaProcessor {
@@ -35,7 +36,7 @@ FeatureBuildItem feature() {
 
   @BuildStep
   AdditionalBeanBuildItem additionalBeans() {
-    return new AdditionalBeanBuildItem(DomaProducer.class);
+    return new AdditionalBeanBuildItem(DomaProducer.class, JtaRequiresNewController.class);
   }
 
   @BuildStep

deployment/src/test/java/org/seasar/doma/quarkus/deployment/InjectConfigTest.java

@@ -2,9 +2,13 @@
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertNotNull;
+import static org.junit.jupiter.api.Assertions.assertTrue;
 
 import io.quarkus.test.QuarkusUnitTest;
 import javax.inject.Inject;
+import javax.transaction.Status;
+import javax.transaction.SystemException;
+import javax.transaction.TransactionManager;
 import org.jboss.shrinkwrap.api.ShrinkWrap;
 import org.jboss.shrinkwrap.api.asset.StringAsset;
 import org.jboss.shrinkwrap.api.spec.JavaArchive;
@@ -35,6 +39,7 @@ public class InjectConfigTest {
   @Inject Entityql entityql;
   @Inject NativeSql nativeSql;
   @Inject ScriptExecutor scriptLoader;
+  @Inject TransactionManager transactionManager;
 
   @Test
   public void test() {
@@ -65,4 +70,19 @@ public void test() {
     assertNotNull(nativeSql);
     assertNotNull(scriptLoader);
   }
+
+  @Test
+  public void requiresNew() throws Throwable {
+    var controller = config.getRequiresNewController();
+    var active =
+        controller.requiresNew(
+            () -> {
+              try {
+                return transactionManager.getStatus() == Status.STATUS_ACTIVE;
+              } catch (SystemException e) {
+                throw new RuntimeException(e);
+              }
+            });
+    assertTrue(active);
+  }
 }

runtime/src/main/java/org/seasar/doma/quarkus/runtime/DomaProducer.java

@@ -119,12 +119,6 @@ JdbcLogger jdbcLogger() {
     return new JBossJdbcLogger(logSettings);
   }
 
-  @ApplicationScoped
-  @DefaultBean
-  RequiresNewController requiresNewController() {
-    return ConfigSupport.defaultRequiresNewController;
-  }
-
   @ApplicationScoped
   @DefaultBean
   ClassHelper classHelper() {

runtime/src/main/java/org/seasar/doma/quarkus/runtime/JtaRequiresNewController.java

@@ -0,0 +1,16 @@
+package org.seasar.doma.quarkus.runtime;
+
+import io.quarkus.arc.DefaultBean;
+import javax.enterprise.context.ApplicationScoped;
+import javax.transaction.Transactional;
+import org.seasar.doma.jdbc.RequiresNewController;
+
+@ApplicationScoped
+@DefaultBean
+public class JtaRequiresNewController implements RequiresNewController {
+  @Override
+  @Transactional(Transactional.TxType.REQUIRES_NEW)
+  public <R> R requiresNew(Callback<R> callback) throws Throwable {
+    return RequiresNewController.super.requiresNew(callback);
+  }
+}