Merge pull request quarkusio#9612 from cescoffier/features/mutiny-poo…

…l-configuration

Configure Mutiny infra to use Quarkus thread pool

bom/runtime/pom.xml

@@ -126,7 +126,7 @@
         <netty.version>4.1.49.Final</netty.version>
         <reactive-streams.version>1.0.3</reactive-streams.version>
         <jboss-logging.version>3.3.2.Final</jboss-logging.version>
-        <mutiny.version>0.5.0</mutiny.version>
+        <mutiny.version>0.5.2</mutiny.version>
         <axle-client.version>0.0.16</axle-client.version>
         <mutiny-client.version>0.0.16</mutiny-client.version>
         <kafka2.version>2.5.0</kafka2.version>

extensions/mutiny/deployment/src/main/java/io/quarkus/mutiny/deployment/MutinyProcessor.java

@@ -1,12 +1,25 @@
 package io.quarkus.mutiny.deployment;
 
+import java.util.concurrent.ExecutorService;
+
 import io.quarkus.deployment.annotations.BuildStep;
+import io.quarkus.deployment.annotations.ExecutionTime;
+import io.quarkus.deployment.annotations.Record;
+import io.quarkus.deployment.builditem.ExecutorBuildItem;
 import io.quarkus.deployment.builditem.FeatureBuildItem;
+import io.quarkus.mutiny.runtime.MutinyInfrastructure;
 
 public class MutinyProcessor {
 
     @BuildStep
     public FeatureBuildItem registerFeature() {
         return new FeatureBuildItem(FeatureBuildItem.MUTINY);
     }
+
+    @BuildStep
+    @Record(ExecutionTime.RUNTIME_INIT)
+    public void initExecutor(ExecutorBuildItem executorBuildItem, MutinyInfrastructure recorder) {
+        ExecutorService executor = executorBuildItem.getExecutorProxy();
+        recorder.configureMutinyInfrastructure(executor);
+    }
 }

extensions/mutiny/runtime/src/main/java/io/quarkus/mutiny/runtime/MutinyInfrastructure.java

@@ -0,0 +1,14 @@
+package io.quarkus.mutiny.runtime;
+
+import java.util.concurrent.ExecutorService;
+
+import io.quarkus.runtime.annotations.Recorder;
+import io.smallrye.mutiny.infrastructure.Infrastructure;
+
+@Recorder
+public class MutinyInfrastructure {
+
+    public void configureMutinyInfrastructure(ExecutorService exec) {
+        Infrastructure.setDefaultExecutor(exec);
+    }
+}

independent-projects/qute/pom.xml

@@ -39,7 +39,7 @@
         <version.gizmo>1.0.3.Final</version.gizmo>
         <version.jboss-logging>3.3.2.Final</version.jboss-logging>
         <version.reactivestreams>1.0.3</version.reactivestreams>
-        <version.mutiny>0.5.0</version.mutiny>
+        <version.mutiny>0.5.2</version.mutiny>
         <version.nexus-staging-maven-plugin>1.6.8</version.nexus-staging-maven-plugin>
     </properties>