Introduce Dev only module for Reactive Messaging extension

Signed-off-by: Phillip Kruger <[email protected]>

Author: phillip-kruger

bom/application/pom.xml

@@ -1799,6 +1799,11 @@
                 <artifactId>quarkus-messaging</artifactId>
                 <version>${project.version}</version>
             </dependency>
+            <dependency>
+                <groupId>io.quarkus</groupId>
+                <artifactId>quarkus-messaging-dev</artifactId>
+                <version>${project.version}</version>
+            </dependency>
             <dependency>
                 <groupId>io.quarkus</groupId>
                 <artifactId>quarkus-messaging-kotlin</artifactId>

extensions/smallrye-reactive-messaging/deployment/pom.xml

@@ -26,6 +26,10 @@
             <groupId>io.quarkus</groupId>
             <artifactId>quarkus-messaging</artifactId>
         </dependency>
+        <dependency>
+            <groupId>io.quarkus</groupId>
+            <artifactId>quarkus-messaging-dev</artifactId>
+        </dependency>
         <dependency>
             <groupId>io.quarkus</groupId>
             <artifactId>quarkus-smallrye-health-spi</artifactId>

extensions/smallrye-reactive-messaging/deployment/src/main/java/io/quarkus/smallrye/reactivemessaging/deployment/devui/ReactiveMessagingDevUIProcessor.java

@@ -10,20 +10,20 @@
 import io.quarkus.arc.deployment.AdditionalBeanBuildItem;
 import io.quarkus.arc.deployment.BeanDiscoveryFinishedBuildItem;
 import io.quarkus.arc.processor.InjectionPointInfo;
-import io.quarkus.deployment.IsDevelopment;
+import io.quarkus.deployment.IsLocalDevelopment;
 import io.quarkus.deployment.annotations.BuildStep;
 import io.quarkus.devui.spi.JsonRPCProvidersBuildItem;
 import io.quarkus.devui.spi.page.CardPageBuildItem;
 import io.quarkus.devui.spi.page.Page;
 import io.quarkus.smallrye.reactivemessaging.deployment.ReactiveMessagingDotNames;
-import io.quarkus.smallrye.reactivemessaging.runtime.devui.Connectors;
-import io.quarkus.smallrye.reactivemessaging.runtime.devui.DevConsoleRecorder;
-import io.quarkus.smallrye.reactivemessaging.runtime.devui.ReactiveMessagingJsonRpcService;
+import io.quarkus.smallrye.reactivemessaging.runtime.dev.ui.Connectors;
+import io.quarkus.smallrye.reactivemessaging.runtime.dev.ui.DevConsoleRecorder;
+import io.quarkus.smallrye.reactivemessaging.runtime.dev.ui.ReactiveMessagingJsonRpcService;
 
 public class ReactiveMessagingDevUIProcessor {
 
     @io.quarkus.deployment.annotations.Record(STATIC_INIT)
-    @BuildStep(onlyIf = IsDevelopment.class)
+    @BuildStep(onlyIf = IsLocalDevelopment.class)
     public void collectInjectionInfo(DevConsoleRecorder recorder, BeanDiscoveryFinishedBuildItem beanDiscoveryFinished) {
         Map<String, String> emitters = new HashMap<>();
         Map<String, String> channels = new HashMap<>();
@@ -48,12 +48,12 @@ public void collectInjectionInfo(DevConsoleRecorder recorder, BeanDiscoveryFinis
         recorder.setInjectionInfo(emitters, channels);
     }
 
-    @BuildStep(onlyIf = IsDevelopment.class)
+    @BuildStep(onlyIf = IsLocalDevelopment.class)
     AdditionalBeanBuildItem beans() {
         return AdditionalBeanBuildItem.unremovableOf(Connectors.class);
     }
 
-    @BuildStep(onlyIf = IsDevelopment.class)
+    @BuildStep(onlyIf = IsLocalDevelopment.class)
     CardPageBuildItem create() {
         CardPageBuildItem card = new CardPageBuildItem();
         card.addPage(Page.webComponentPageBuilder()
@@ -64,7 +64,7 @@ CardPageBuildItem create() {
         return card;
     }
 
-    @BuildStep
+    @BuildStep(onlyIf = IsLocalDevelopment.class)
     JsonRPCProvidersBuildItem createJsonRPCServiceForCache() {
         return new JsonRPCProvidersBuildItem(ReactiveMessagingJsonRpcService.class);
     }

extensions/smallrye-reactive-messaging/pom.xml

@@ -18,5 +18,6 @@
       <module>deployment</module>
       <module>kotlin</module>
       <module>runtime</module>
+      <module>runtime-dev</module>
    </modules>
 </project>

extensions/smallrye-reactive-messaging/runtime-dev/pom.xml

@@ -0,0 +1,20 @@
+<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>quarkus-messaging-parent</artifactId>
+        <groupId>io.quarkus</groupId>
+        <version>999-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+    <artifactId>quarkus-messaging-dev</artifactId>
+    <name>Quarkus - Messaging - Runtime Dev mode</name>
+    <description>Produce and consume messages and implement event driven and data streaming applications - Dev mode only</description>
+    <dependencies>
+        <dependency>
+            <groupId>io.quarkus</groupId>
+            <artifactId>quarkus-messaging</artifactId>
+        </dependency>
+    </dependencies>
+</project>

extensions/smallrye-reactive-messaging/runtime/src/main/java/io/quarkus/smallrye/reactivemessaging/runtime/devui/Connectors.java renamed to extensions/smallrye-reactive-messaging/runtime-dev/src/main/java/io/quarkus/smallrye/reactivemessaging/runtime/dev/ui/Connectors.java

@@ -1,4 +1,4 @@
-package io.quarkus.smallrye.reactivemessaging.runtime.devui;
+package io.quarkus.smallrye.reactivemessaging.runtime.dev.ui;
 
 import java.util.ArrayList;
 import java.util.HashMap;
@@ -12,8 +12,8 @@
 import org.eclipse.microprofile.config.Config;
 
 import io.quarkus.runtime.StartupEvent;
-import io.quarkus.smallrye.reactivemessaging.runtime.devui.DevReactiveMessagingInfos.Component;
-import io.quarkus.smallrye.reactivemessaging.runtime.devui.DevReactiveMessagingInfos.ComponentType;
+import io.quarkus.smallrye.reactivemessaging.runtime.dev.ui.DevReactiveMessagingInfos.Component;
+import io.quarkus.smallrye.reactivemessaging.runtime.dev.ui.DevReactiveMessagingInfos.ComponentType;
 
 // we use a separate component due to weird class loading issues that occur when accessing config properties
 @Singleton

extensions/smallrye-reactive-messaging/runtime/src/main/java/io/quarkus/smallrye/reactivemessaging/runtime/devui/DevConsoleRecorder.java renamed to extensions/smallrye-reactive-messaging/runtime-dev/src/main/java/io/quarkus/smallrye/reactivemessaging/runtime/dev/ui/DevConsoleRecorder.java

@@ -1,4 +1,4 @@
-package io.quarkus.smallrye.reactivemessaging.runtime.devui;
+package io.quarkus.smallrye.reactivemessaging.runtime.dev.ui;
 
 import java.util.HashMap;
 import java.util.Map;

extensions/smallrye-reactive-messaging/runtime/src/main/java/io/quarkus/smallrye/reactivemessaging/runtime/devui/DevReactiveMessagingInfos.java renamed to extensions/smallrye-reactive-messaging/runtime-dev/src/main/java/io/quarkus/smallrye/reactivemessaging/runtime/dev/ui/DevReactiveMessagingInfos.java

@@ -1,4 +1,4 @@
-package io.quarkus.smallrye.reactivemessaging.runtime.devui;
+package io.quarkus.smallrye.reactivemessaging.runtime.dev.ui;
 
 import java.util.ArrayList;
 import java.util.Collections;

extensions/smallrye-reactive-messaging/runtime/src/main/java/io/quarkus/smallrye/reactivemessaging/runtime/devui/ReactiveMessagingJsonRpcService.java renamed to extensions/smallrye-reactive-messaging/runtime-dev/src/main/java/io/quarkus/smallrye/reactivemessaging/runtime/dev/ui/ReactiveMessagingJsonRpcService.java

@@ -1,4 +1,4 @@
-package io.quarkus.smallrye.reactivemessaging.runtime.devui;
+package io.quarkus.smallrye.reactivemessaging.runtime.dev.ui;
 
 import java.util.List;
 

extensions/smallrye-reactive-messaging/runtime/pom.xml

@@ -92,6 +92,9 @@
                         <provides>io.quarkus.smallrye.reactive.messaging</provides>
                         <provides>io.quarkus.messaging</provides>
                     </capabilities>
+                    <conditionalDevDependencies>
+                        <artifact>${project.groupId}:${project.artifactId}-dev:${project.version}</artifact>
+                    </conditionalDevDependencies>
                 </configuration>
             </plugin>
             <plugin>