Add ArtemisJmsRABuildItem

quarkiverse · Aug 1, 2024 · afb15dd · afb15dd
1 parent f03561e
commit afb15dd
Show file tree

Hide file tree

Showing 4 changed files with 24 additions and 5 deletions.
diff --git a/core/deployment/src/main/java/io/quarkus/artemis/core/deployment/ArtemisCoreProcessor.java b/core/deployment/src/main/java/io/quarkus/artemis/core/deployment/ArtemisCoreProcessor.java
@@ -55,8 +55,9 @@ public class ArtemisCoreProcessor {
 
     @SuppressWarnings("unused")
     @BuildStep
-    FeatureBuildItem feature(Optional<ArtemisJmsBuildItem> artemisJms) {
-        if (artemisJms.isEmpty()) {
+    FeatureBuildItem feature(Optional<ArtemisJmsBuildItem> artemisJms,
+                             Optional<ArtemisJmsRABuildItem> ra) {
+        if (artemisJms.isEmpty() && ra.isEmpty()) {
             return new FeatureBuildItem(FEATURE);
         }
         return null;
@@ -109,8 +110,9 @@ ArtemisCoreConfiguredBuildItem configure(
             ArtemisBuildTimeConfigs buildTimeConfigs,
             ArtemisBootstrappedBuildItem bootstrap,
             BuildProducer<SyntheticBeanBuildItem> syntheticBeanProducer,
-            Optional<ArtemisJmsBuildItem> artemisJms) {
-        if (artemisJms.isPresent()) {
+            Optional<ArtemisJmsBuildItem> artemisJms,
+            Optional<ArtemisJmsRABuildItem> ra) {
+        if (artemisJms.isPresent() || ra.isPresent()) {
             return null;
         }
         if (shadowRunTimeConfigs.isEmpty() && buildTimeConfigs.isEmpty()) {

diff --git a/core/deployment/src/main/java/io/quarkus/artemis/core/deployment/ArtemisJmsRABuildItem.java b/core/deployment/src/main/java/io/quarkus/artemis/core/deployment/ArtemisJmsRABuildItem.java
@@ -0,0 +1,9 @@
+package io.quarkus.artemis.core.deployment;
+
+import io.quarkus.builder.item.SimpleBuildItem;
+
+/**
+ * Marker build item indicating that RA is enabled
+ */
+public class ArtemisJmsRABuildItem extends SimpleBuildItem {
+}
diff --git a/...yment/src/main/java/io/quarkus/artemis/core/deployment/health/ArtemisHealthProcessor.java b/...yment/src/main/java/io/quarkus/artemis/core/deployment/health/ArtemisHealthProcessor.java
@@ -6,6 +6,7 @@
 import java.util.Optional;
 import java.util.Set;
 
+import io.quarkus.artemis.core.deployment.ArtemisJmsRABuildItem;
 import jakarta.enterprise.context.ApplicationScoped;
 
 import io.quarkus.arc.deployment.SyntheticBeanBuildItem;
@@ -77,8 +78,9 @@ private static Set<String> processConfigs(
     HealthBuildItem healthChecks(
             Capabilities capabilities,
             Optional<ArtemisJmsBuildItem> artemisJms,
+            Optional<ArtemisJmsRABuildItem> ra,
             Optional<ArtemisHealthSupportBuildItem> artemisHealthSupportBuildItem) {
-        if (artemisJms.isPresent()) {
+        if (artemisJms.isPresent() || ra.isPresent()) {
             return null;
         }
         if (artemisHealthSupportBuildItem.isEmpty()) {

diff --git a/...t/src/main/java/io/quarkus/artemis/jms/ra/deployment/ArtemisResourceAdapterProcessor.java b/...t/src/main/java/io/quarkus/artemis/jms/ra/deployment/ArtemisResourceAdapterProcessor.java
@@ -2,6 +2,7 @@
 
 import java.util.Map.Entry;
 
+import io.quarkus.artemis.core.deployment.ArtemisJmsRABuildItem;
 import jakarta.enterprise.context.ApplicationScoped;
 import jakarta.enterprise.inject.Default;
 
@@ -29,6 +30,11 @@ FeatureBuildItem feature() {
         return new FeatureBuildItem(FEATURE);
     }
 
+    @BuildStep
+    void load(BuildProducer<ArtemisJmsRABuildItem> ra) {
+        ra.produce(new ArtemisJmsRABuildItem());
+    }
+
     @Record(ExecutionTime.RUNTIME_INIT)
     @BuildStep
     void setupServerLocatorForHealthCheck(ArtemisResourceAdapterRecorder recorder,