Support Virtual Threads in the WorkManager

- Fixes #147

Author: gastaldi

deployment/pom.xml

@@ -25,6 +25,10 @@
       <groupId>io.quarkus</groupId>
       <artifactId>quarkus-smallrye-context-propagation-deployment</artifactId>
     </dependency>
+    <dependency>
+      <groupId>io.quarkus</groupId>
+      <artifactId>quarkus-virtual-threads-deployment</artifactId>
+    </dependency>
     <dependency>
       <groupId>io.quarkiverse.ironjacamar</groupId>
       <artifactId>quarkus-ironjacamar</artifactId>

docs/modules/ROOT/pages/includes/quarkus-ironjacamar.adoc

@@ -119,7 +119,7 @@ ifndef::add-copy-button-to-env-var[]
 Environment variable: `+++QUARKUS_IRONJACAMAR_RA_CM_TRANSACTION_SUPPORT_LEVEL+++`
 endif::add-copy-button-to-env-var[]
 --
-a|TransactionSupportLevel
+a|`no-transaction`, `local-transaction`, `xa-transaction`
 |`xa-transaction`
 
 a| [[quarkus-ironjacamar_quarkus-ironjacamar-ra-cm-allocation-retry]] [.property-path]##link:#quarkus-ironjacamar_quarkus-ironjacamar-ra-cm-allocation-retry[`quarkus.ironjacamar.ra.cm.allocation-retry`]##
@@ -195,7 +195,7 @@ ifndef::add-copy-button-to-env-var[]
 Environment variable: `+++QUARKUS_IRONJACAMAR_RA_CM_FLUSH_STRATEGY+++`
 endif::add-copy-button-to-env-var[]
 --
-a|FlushStrategy
+a|`unknown`, `failing-connection-only`, `invalid-idle-connections`, `idle-connections`, `gracefully`, `entire-pool`, `all-invalid-idle-connections`, `all-idle-connections`, `all-gracefully`, `all-connections`
 |`failing-connection-only`
 
 a| [[quarkus-ironjacamar_quarkus-ironjacamar-ra-cm-sharable]] [.property-path]##link:#quarkus-ironjacamar_quarkus-ironjacamar-ra-cm-sharable[`quarkus.ironjacamar.ra.cm.sharable`]##
@@ -442,7 +442,7 @@ ifndef::add-copy-button-to-env-var[]
 Environment variable: `+++QUARKUS_IRONJACAMAR_RA_CM_POOL_STRATEGY+++`
 endif::add-copy-button-to-env-var[]
 --
-a|PoolStrategy
+a|`pool-by-cri`, `pool-by-subject`, `pool-by-subject-and-cri`, `one-pool`, `reauth`
 |`pool-by-cri`
 
 a| [[quarkus-ironjacamar_quarkus-ironjacamar-ra-cm-pool-config-min-size]] [.property-path]##link:#quarkus-ironjacamar_quarkus-ironjacamar-ra-cm-pool-config-min-size[`quarkus.ironjacamar.ra.cm.pool.config.min-size`]##

docs/modules/ROOT/pages/includes/quarkus-ironjacamar_quarkus.ironjacamar.adoc

@@ -119,7 +119,7 @@ ifndef::add-copy-button-to-env-var[]
 Environment variable: `+++QUARKUS_IRONJACAMAR_RA_CM_TRANSACTION_SUPPORT_LEVEL+++`
 endif::add-copy-button-to-env-var[]
 --
-a|TransactionSupportLevel
+a|`no-transaction`, `local-transaction`, `xa-transaction`
 |`xa-transaction`
 
 a| [[quarkus-ironjacamar_quarkus-ironjacamar-ra-cm-allocation-retry]] [.property-path]##link:#quarkus-ironjacamar_quarkus-ironjacamar-ra-cm-allocation-retry[`quarkus.ironjacamar.ra.cm.allocation-retry`]##
@@ -195,7 +195,7 @@ ifndef::add-copy-button-to-env-var[]
 Environment variable: `+++QUARKUS_IRONJACAMAR_RA_CM_FLUSH_STRATEGY+++`
 endif::add-copy-button-to-env-var[]
 --
-a|FlushStrategy
+a|`unknown`, `failing-connection-only`, `invalid-idle-connections`, `idle-connections`, `gracefully`, `entire-pool`, `all-invalid-idle-connections`, `all-idle-connections`, `all-gracefully`, `all-connections`
 |`failing-connection-only`
 
 a| [[quarkus-ironjacamar_quarkus-ironjacamar-ra-cm-sharable]] [.property-path]##link:#quarkus-ironjacamar_quarkus-ironjacamar-ra-cm-sharable[`quarkus.ironjacamar.ra.cm.sharable`]##
@@ -442,7 +442,7 @@ ifndef::add-copy-button-to-env-var[]
 Environment variable: `+++QUARKUS_IRONJACAMAR_RA_CM_POOL_STRATEGY+++`
 endif::add-copy-button-to-env-var[]
 --
-a|PoolStrategy
+a|`pool-by-cri`, `pool-by-subject`, `pool-by-subject-and-cri`, `one-pool`, `reauth`
 |`pool-by-cri`
 
 a| [[quarkus-ironjacamar_quarkus-ironjacamar-ra-cm-pool-config-min-size]] [.property-path]##link:#quarkus-ironjacamar_quarkus-ironjacamar-ra-cm-pool-config-min-size[`quarkus.ironjacamar.ra.cm.pool.config.min-size`]##

pom.xml

@@ -22,8 +22,8 @@
     <tag>HEAD</tag>
   </scm>
   <properties>
-    <quarkus.version>3.15.1</quarkus.version>
-    <ironjacamar.version>3.0.11.Final</ironjacamar.version>
+    <quarkus.version>3.15.3</quarkus.version>
+    <ironjacamar.version>3.0.10.Final</ironjacamar.version>
   </properties>
   <dependencyManagement>
     <dependencies>
@@ -42,7 +42,7 @@
       <dependency>
         <groupId>org.assertj</groupId>
         <artifactId>assertj-core</artifactId>
-        <version>3.27.3</version>
+        <version>3.27.2</version>
         <scope>test</scope>
       </dependency>
     </dependencies>

runtime/pom.xml

@@ -26,6 +26,10 @@
       <groupId>io.quarkus</groupId>
       <artifactId>quarkus-smallrye-context-propagation</artifactId>
     </dependency>
+    <dependency>
+      <groupId>io.quarkus</groupId>
+      <artifactId>quarkus-virtual-threads</artifactId>
+    </dependency>
     <dependency>
       <groupId>jakarta.resource</groupId>
       <artifactId>jakarta.resource-api</artifactId>

runtime/src/main/java/io/quarkiverse/ironjacamar/runtime/IronJacamarRecorder.java

@@ -6,14 +6,14 @@
 import java.time.Duration;
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.ExecutorService;
 import java.util.concurrent.TimeUnit;
 import java.util.function.Function;
 import java.util.function.Supplier;
 
 import jakarta.enterprise.inject.spi.DeploymentException;
 import jakarta.resource.ResourceException;
 
-import org.eclipse.microprofile.context.ManagedExecutor;
 import org.jboss.jca.core.api.bootstrap.CloneableBootstrapContext;
 import org.jboss.jca.core.api.connectionmanager.ccm.CachedConnectionManager;
 import org.jboss.jca.core.bootstrapcontext.BaseCloneableBootstrapContext;
@@ -33,6 +33,7 @@
 import io.quarkus.narayana.jta.runtime.TransactionManagerConfiguration;
 import io.quarkus.runtime.RuntimeValue;
 import io.quarkus.runtime.annotations.Recorder;
+import io.quarkus.virtual.threads.VirtualThreadsRecorder;
 import io.smallrye.common.annotation.Identifier;
 import io.vertx.core.DeploymentOptions;
 import io.vertx.core.Future;
@@ -131,7 +132,7 @@ public void initDefaultBootstrapContext(BeanContainer beanContainer) {
         TransactionIntegration transactionIntegration = beanContainer.beanInstance(TransactionIntegration.class);
         SecurityIntegration securityIntegration = beanContainer.beanInstance(QuarkusSecurityIntegration.class);
         BaseCloneableBootstrapContext bootstrapContext = new BaseCloneableBootstrapContext();
-        ManagedExecutor executorService = beanContainer.beanInstance(ManagedExecutor.class);
+        ExecutorService executorService = VirtualThreadsRecorder.getCurrent();
 
         // Create WorkManagerImpl
         WorkManagerImpl workManager = new WorkManagerImpl();