ArC and Vert.x: introduce InvokerFactoryBuildItem and use it in Vert.x event bus consumers

bom/application/pom.xml

@@ -1907,6 +1907,11 @@
                 <artifactId>quarkus-vertx-deployment</artifactId>
                 <version>${project.version}</version>
             </dependency>
+            <dependency>
+                <groupId>io.quarkus</groupId>
+                <artifactId>quarkus-vertx-deployment-spi</artifactId>
+                <version>${project.version}</version>
+            </dependency>
             <dependency>
                 <groupId>io.quarkus</groupId>
                 <artifactId>quarkus-vertx-latebound-mdc-provider</artifactId>
@@ -1952,6 +1957,16 @@
                 <artifactId>quarkus-vertx-http-dev-ui-resources</artifactId>
                 <version>${project.version}</version>
             </dependency>
+            <dependency>
+                <groupId>io.quarkus</groupId>
+                <artifactId>quarkus-vertx-kotlin</artifactId>
+                <version>${project.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>io.quarkus</groupId>
+                <artifactId>quarkus-vertx-kotlin-deployment</artifactId>
+                <version>${project.version}</version>
+            </dependency>
 
             <dependency>
                 <groupId>io.quarkus</groupId>

devtools/bom-descriptor-json/pom.xml

@@ -2943,6 +2943,19 @@
                         </exclusion>
                     </exclusions>
                 </dependency>
+                <dependency>
+                    <groupId>io.quarkus</groupId>
+                    <artifactId>quarkus-vertx-kotlin</artifactId>
+                    <version>${project.version}</version>
+                    <type>pom</type>
+                    <scope>test</scope>
+                    <exclusions>
+                        <exclusion>
+                            <groupId>*</groupId>
+                            <artifactId>*</artifactId>
+                        </exclusion>
+                    </exclusions>
+                </dependency>
                 <dependency>
                     <groupId>io.quarkus</groupId>
                     <artifactId>quarkus-virtual-threads</artifactId>

docs/pom.xml

@@ -2955,6 +2955,19 @@
                 </exclusion>
             </exclusions>
         </dependency>
+        <dependency>
+            <groupId>io.quarkus</groupId>
+            <artifactId>quarkus-vertx-kotlin-deployment</artifactId>
+            <version>${project.version}</version>
+            <type>pom</type>
+            <scope>test</scope>
+            <exclusions>
+                <exclusion>
+                    <groupId>*</groupId>
+                    <artifactId>*</artifactId>
+                </exclusion>
+            </exclusions>
+        </dependency>
         <dependency>
             <groupId>io.quarkus</groupId>
             <artifactId>quarkus-virtual-threads-deployment</artifactId>

docs/src/main/asciidoc/kotlin.adoc

@@ -501,9 +501,12 @@
 |`quarkus-smallrye-fault-tolerance`
 |Support is provided for the declarative annotation-based API
 
+|`quarkus-vertx`
+|Support is provided for `@ConsumeEvent` methods
+
 |===
 
 === Kotlin coroutines and Mutiny
 
 Kotlin coroutines provide an imperative programming model that actually gets executed in an asynchronous, reactive manner.
 To simplify the interoperability between Mutiny and Kotlin there is the module `io.smallrye.reactive:mutiny-kotlin`, described link:https://smallrye.io/smallrye-mutiny/latest/guides/kotlin/[here].

extensions/arc/deployment/src/main/java/io/quarkus/arc/deployment/ArcProcessor.java

@@ -425,7 +425,8 @@ public BeanRegistrationPhaseBuildItem registerBeans(ContextRegistrationPhaseBuil
             List<ContextConfiguratorBuildItem> contextConfigurationRegistry,
             BuildProducer<InterceptorResolverBuildItem> interceptorResolver,
             BuildProducer<BeanDiscoveryFinishedBuildItem> beanDiscoveryFinished,
-            BuildProducer<TransformedAnnotationsBuildItem> transformedAnnotations) {
+            BuildProducer<TransformedAnnotationsBuildItem> transformedAnnotations,
+            BuildProducer<InvokerFactoryBuildItem> invokerFactory) {
 
         for (ContextConfiguratorBuildItem contextConfigurator : contextConfigurationRegistry) {
             for (ContextConfigurator value : contextConfigurator.getValues()) {
@@ -440,6 +441,7 @@ public BeanRegistrationPhaseBuildItem registerBeans(ContextRegistrationPhaseBuil
         interceptorResolver.produce(new InterceptorResolverBuildItem(beanDeployment));
         beanDiscoveryFinished.produce(new BeanDiscoveryFinishedBuildItem(beanDeployment));
         transformedAnnotations.produce(new TransformedAnnotationsBuildItem(beanDeployment));
+        invokerFactory.produce(new InvokerFactoryBuildItem(beanDeployment));
 
         return new BeanRegistrationPhaseBuildItem(registrationContext, beanProcessor);
     }

extensions/arc/deployment/src/main/java/io/quarkus/arc/deployment/InvokerFactoryBuildItem.java

@@ -0,0 +1,28 @@
+package io.quarkus.arc.deployment;
+
+import org.jboss.jandex.MethodInfo;
+
+import io.quarkus.arc.processor.BeanDeployment;
+import io.quarkus.arc.processor.BeanInfo;
+import io.quarkus.arc.processor.InvokerBuilder;
+import io.quarkus.arc.processor.InvokerFactory;
+import io.quarkus.builder.item.SimpleBuildItem;
+
+/**
+ * Provides access to {@link InvokerFactory}. May only be used in the bean registration phase,
+ * observer registration phase, and validation phase (basically, until ArC generates
+ * the classes). Afterwards, any attempt to call {@link #createInvoker(BeanInfo, MethodInfo)}
+ * throws an exception.
+ */
+public final class InvokerFactoryBuildItem extends SimpleBuildItem {
+    private final BeanDeployment beanDeployment;
+
+    public InvokerFactoryBuildItem(BeanDeployment beanDeployment) {
+        this.beanDeployment = beanDeployment;
+    }
+
+    public InvokerBuilder createInvoker(BeanInfo bean, MethodInfo method) {
+        // always call `BeanDeployment.getInvokerFactory()`, because that checks whether it's too late
+        return beanDeployment.getInvokerFactory().createInvoker(bean, method);
+    }
+}

extensions/kotlin/deployment/pom.xml

@@ -28,6 +28,11 @@
             <artifactId>kotlin-compiler</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>io.quarkus</groupId>
+            <artifactId>quarkus-vertx-kotlin-deployment</artifactId>
+            <optional>true</optional>
+        </dependency>
     </dependencies>
 
     <build>

extensions/kotlin/runtime/pom.xml

@@ -78,5 +78,11 @@
             <groupId>org.jetbrains.kotlinx</groupId>
             <artifactId>kotlinx-coroutines-jdk8</artifactId>
         </dependency>
+
+        <dependency>
+            <groupId>io.quarkus</groupId>
+            <artifactId>quarkus-vertx-kotlin</artifactId>
+            <optional>true</optional>
+        </dependency>
     </dependencies>
 </project>

extensions/vertx/deployment-spi/pom.xml

@@ -0,0 +1,26 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>quarkus-vertx-parent</artifactId>
+        <groupId>io.quarkus</groupId>
+        <version>999-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>quarkus-vertx-deployment-spi</artifactId>
+    <name>Quarkus - Vert.x - Deployment - SPI</name>
+
+    <dependencies>
+        <dependency>
+            <groupId>io.quarkus</groupId>
+            <artifactId>quarkus-core-deployment</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>io.quarkus.arc</groupId>
+            <artifactId>arc-processor</artifactId>
+        </dependency>
+    </dependencies>
+
+</project>

extensions/vertx/deployment-spi/src/main/java/io/quarkus/vertx/deployment/spi/EventConsumerInvokerCustomizerBuildItem.java

@@ -0,0 +1,24 @@
+package io.quarkus.vertx.deployment.spi;
+
+import java.util.function.BiConsumer;
+
+import org.jboss.jandex.MethodInfo;
+
+import io.quarkus.arc.processor.InvokerBuilder;
+import io.quarkus.builder.item.MultiBuildItem;
+
+/**
+ * This build item should be considered private and should not be used outside of core Quarkus.
+ * It can be changed without notice.
+ */
+public final class EventConsumerInvokerCustomizerBuildItem extends MultiBuildItem {
+    private final BiConsumer<MethodInfo, InvokerBuilder> invokerCustomizer;
+
+    public EventConsumerInvokerCustomizerBuildItem(BiConsumer<MethodInfo, InvokerBuilder> invokerCustomizer) {
+        this.invokerCustomizer = invokerCustomizer;
+    }
+
+    public BiConsumer<MethodInfo, InvokerBuilder> getInvokerCustomizer() {
+        return invokerCustomizer;
+    }
+}

extensions/vertx/deployment/pom.xml

@@ -37,6 +37,10 @@
             <groupId>io.quarkus</groupId>
             <artifactId>quarkus-jackson-spi</artifactId>
         </dependency>
+        <dependency>
+            <groupId>io.quarkus</groupId>
+            <artifactId>quarkus-vertx-deployment-spi</artifactId>
+        </dependency>
         <dependency>
             <groupId>io.quarkus</groupId>
             <artifactId>quarkus-junit5-internal</artifactId>