Run NATS tests in GitHub Actions

sonus21 · sonus21 · commit 2b7b8e8f482a · 2026-04-30T18:00:55.000+05:30
Adds @tag("nats") meta-annotations (@NatsIntegrationTest and @NatsUnitTest) in rqueue-nats and applies them to the JetStream test files; tags RqueueNatsAutoConfigTest, RqueueNatsListenerConfigTest, and NatsBackendEndToEndIT directly. NatsUnitTest deliberately omits the MockitoExtension because the existing tests use Mockito.mock() directly and adding the extension would activate strict-stubbing. Adds a nats_integration_test job to java-ci.yaml that runs :rqueue-nats:test :rqueue-spring-boot-starter:test :rqueue-spring:test with -DincludeTags=nats. Docker is preinstalled on ubuntu-latest, so Testcontainers picks it up automatically and the JetStream ITs run against nats:2.10-alpine -js. Coverage from this job is fed into the existing coverage_report job. Local verification: the same gradle invocation reports 13 tests run, 9 skipped (Docker-gated ITs without local Docker), 0 failures. Assisted-By: Claude Code
diff --git a/.github/workflows/java-ci.yaml b/.github/workflows/java-ci.yaml
@@ -336,13 +336,63 @@ jobs:
             rqueue-core/build/reports/junit/xml
           if-no-files-found: ignore
 
+  nats_integration_test:
+    needs: build
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout
+        uses: actions/checkout@v4
+
+      - name: Set up Java 21
+        uses: actions/setup-java@v4
+        with:
+          distribution: temurin
+          java-version: "21"
+          cache: gradle
+
+      - name: Expose Java 21 to Gradle toolchains
+        run: |
+          echo "JAVA_HOME=$JAVA_HOME" >> "$GITHUB_ENV"
+          echo "ORG_GRADLE_JAVA_INSTALLATIONS_PATHS=$JAVA_HOME" >> "$GITHUB_ENV"
+          java -version
+          javac -version
+
+      - name: Set up Gradle
+        uses: gradle/actions/setup-gradle@v4
+
+      # Docker is preinstalled on ubuntu-latest runners; Testcontainers picks it up
+      # automatically. No Redis is needed for this job — every test under @Tag("nats")
+      # talks to a JetStream container via Testcontainers (or runs as a pure unit test).
+      - name: Run NATS tests
+        run: ./gradlew :rqueue-nats:test :rqueue-spring-boot-starter:test :rqueue-spring:test -DincludeTags=nats
+
+      - name: Upload JaCoCo exec data
+        if: always()
+        uses: actions/upload-artifact@v4
+        with:
+          name: coverage-nats
+          path: "**/build/reports/jacoco/*.exec"
+          if-no-files-found: error
+
+      - name: Upload JUnit reports
+        if: always()
+        uses: actions/upload-artifact@v4
+        with:
+          name: nats-test-results
+          path: |
+            rqueue-nats/build/reports/junit/xml
+            rqueue-spring-boot-starter/build/reports/junit/xml
+            rqueue-spring/build/reports/junit/xml
+          if-no-files-found: ignore
+
   coverage_report:
     needs:
       - unit_test
       - producer_only_test
       - integration_test
       - redis_cluster_test
       - reactive_integration_test
+      - nats_integration_test
     runs-on: ubuntu-latest
     steps:
       - name: Checkout
diff --git a/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/AbstractJetStreamIT.java b/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/AbstractJetStreamIT.java
@@ -29,6 +29,7 @@
  * skips these tests automatically.
  */
 @Testcontainers(disabledWithoutDocker = true)
+@NatsIntegrationTest
 abstract class AbstractJetStreamIT {
 
   @Container
diff --git a/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/JetStreamMessageBrokerCompetingConsumersIT.java b/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/JetStreamMessageBrokerCompetingConsumersIT.java
@@ -21,6 +21,7 @@
 import java.util.concurrent.Executors;
 import org.junit.jupiter.api.Test;
 
+@NatsIntegrationTest
 class JetStreamMessageBrokerCompetingConsumersIT extends AbstractJetStreamIT {
 
   @Test
diff --git a/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/JetStreamMessageBrokerDedupIT.java b/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/JetStreamMessageBrokerDedupIT.java
@@ -15,6 +15,7 @@
 import com.github.sonus21.rqueue.listener.QueueDetail;
 import org.junit.jupiter.api.Test;
 
+@NatsIntegrationTest
 class JetStreamMessageBrokerDedupIT extends AbstractJetStreamIT {
 
   @Test
diff --git a/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/JetStreamMessageBrokerDelayThrowsTest.java b/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/JetStreamMessageBrokerDelayThrowsTest.java
@@ -25,6 +25,7 @@
 import tools.jackson.databind.ObjectMapper;
 
 /** Unit tests that exercise pure-Java code paths (no docker container needed). */
+@NatsUnitTest
 class JetStreamMessageBrokerDelayThrowsTest {
 
   private JetStreamMessageBroker newBroker() {
diff --git a/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/JetStreamMessageBrokerEnqueueAckIT.java b/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/JetStreamMessageBrokerEnqueueAckIT.java
@@ -19,6 +19,7 @@
 import java.util.List;
 import org.junit.jupiter.api.Test;
 
+@NatsIntegrationTest
 class JetStreamMessageBrokerEnqueueAckIT extends AbstractJetStreamIT {
 
   @Test
diff --git a/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/JetStreamMessageBrokerIndependentConsumersIT.java b/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/JetStreamMessageBrokerIndependentConsumersIT.java
@@ -19,6 +19,7 @@
 import java.util.Set;
 import org.junit.jupiter.api.Test;
 
+@NatsIntegrationTest
 class JetStreamMessageBrokerIndependentConsumersIT extends AbstractJetStreamIT {
 
   @Test
diff --git a/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/JetStreamMessageBrokerPeekIT.java b/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/JetStreamMessageBrokerPeekIT.java
@@ -17,6 +17,7 @@
 import java.util.List;
 import org.junit.jupiter.api.Test;
 
+@NatsIntegrationTest
 class JetStreamMessageBrokerPeekIT extends AbstractJetStreamIT {
 
   @Test
diff --git a/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/JetStreamMessageBrokerPubSubIT.java b/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/JetStreamMessageBrokerPubSubIT.java
@@ -16,6 +16,7 @@
 import java.util.concurrent.TimeUnit;
 import org.junit.jupiter.api.Test;
 
+@NatsIntegrationTest
 class JetStreamMessageBrokerPubSubIT extends AbstractJetStreamIT {
 
   @Test
diff --git a/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/JetStreamMessageBrokerReactiveEnqueueIT.java b/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/JetStreamMessageBrokerReactiveEnqueueIT.java
@@ -18,6 +18,7 @@
 import reactor.core.publisher.Mono;
 import reactor.test.StepVerifier;
 
+@NatsIntegrationTest
 class JetStreamMessageBrokerReactiveEnqueueIT extends AbstractJetStreamIT {
 
   @Test
diff --git a/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/JetStreamMessageBrokerRetryDlqIT.java b/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/JetStreamMessageBrokerRetryDlqIT.java
@@ -17,6 +17,7 @@
 import java.util.List;
 import org.junit.jupiter.api.Test;
 
+@NatsIntegrationTest
 class JetStreamMessageBrokerRetryDlqIT extends AbstractJetStreamIT {
 
   @Test
diff --git a/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/NatsIntegrationTest.java b/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/NatsIntegrationTest.java
@@ -0,0 +1,31 @@
+/*
+ * Copyright (c) 2024-2026 Sonu Kumar
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * You may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     https://www.apache.org/licenses/LICENSE-2.0
+ */
+
+package com.github.sonus21.rqueue.nats;
+
+import com.github.sonus21.junit.TestTracerExtension;
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+import org.junit.jupiter.api.Tag;
+import org.junit.jupiter.api.extension.ExtendWith;
+
+/**
+ * Meta-annotation for Docker-gated JetStream integration tests. Carries both {@code integration}
+ * and {@code nats} tags so CI can select them via {@code -DincludeTags=nats} without spinning up
+ * Redis, while still surfacing in any pipeline that asks for {@code integration} tests.
+ */
+@Target({ElementType.TYPE})
+@Retention(RetentionPolicy.RUNTIME)
+@Tag("integration")
+@Tag("nats")
+@ExtendWith(TestTracerExtension.class)
+public @interface NatsIntegrationTest {}
diff --git a/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/NatsUnitTest.java b/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/NatsUnitTest.java
@@ -0,0 +1,31 @@
+/*
+ * Copyright (c) 2024-2026 Sonu Kumar
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * You may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     https://www.apache.org/licenses/LICENSE-2.0
+ */
+
+package com.github.sonus21.rqueue.nats;
+
+import com.github.sonus21.junit.TestTracerExtension;
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+import org.junit.jupiter.api.Tag;
+import org.junit.jupiter.api.extension.ExtendWith;
+
+/**
+ * NATS unit tests; tagged so CI's {@code unit_test} job picks them up. Intentionally does not
+ * include {@code MockitoExtension} — the existing tests use {@code Mockito.mock()} directly and
+ * adding the extension would activate strict-stubbing and flag setup-only stubs as unnecessary.
+ */
+@Target({ElementType.TYPE})
+@Retention(RetentionPolicy.RUNTIME)
+@Tag("unit")
+@Tag("nats")
+@ExtendWith(TestTracerExtension.class)
+public @interface NatsUnitTest {}
diff --git a/rqueue-spring-boot-starter/src/test/java/com/github/sonus21/rqueue/spring/boot/RqueueNatsAutoConfigTest.java b/rqueue-spring-boot-starter/src/test/java/com/github/sonus21/rqueue/spring/boot/RqueueNatsAutoConfigTest.java
@@ -23,12 +23,15 @@
 import io.nats.client.Connection;
 import io.nats.client.JetStream;
 import io.nats.client.JetStreamManagement;
+import org.junit.jupiter.api.Tag;
 import org.junit.jupiter.api.Test;
 import org.springframework.boot.autoconfigure.AutoConfigurations;
 import org.springframework.boot.test.context.runner.ApplicationContextRunner;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
+@Tag("unit")
+@Tag("nats")
 class RqueueNatsAutoConfigTest {
 
   private final ApplicationContextRunner runner = new ApplicationContextRunner()
diff --git a/rqueue-spring-boot-starter/src/test/java/com/github/sonus21/rqueue/spring/boot/integration/NatsBackendEndToEndIT.java b/rqueue-spring-boot-starter/src/test/java/com/github/sonus21/rqueue/spring/boot/integration/NatsBackendEndToEndIT.java
@@ -24,6 +24,7 @@
 import java.util.List;
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.TimeUnit;
+import org.junit.jupiter.api.Tag;
 import org.junit.jupiter.api.Test;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
@@ -69,6 +70,8 @@
     classes = NatsBackendEndToEndIT.TestApp.class,
     properties = {"rqueue.backend=nats"})
 @Testcontainers(disabledWithoutDocker = true)
+@Tag("integration")
+@Tag("nats")
 class NatsBackendEndToEndIT {
 
   @Container
diff --git a/rqueue-spring/src/test/java/com/github/sonus21/rqueue/spring/RqueueNatsListenerConfigTest.java b/rqueue-spring/src/test/java/com/github/sonus21/rqueue/spring/RqueueNatsListenerConfigTest.java
@@ -24,11 +24,14 @@
 import io.nats.client.Connection;
 import io.nats.client.JetStream;
 import io.nats.client.JetStreamManagement;
+import org.junit.jupiter.api.Tag;
 import org.junit.jupiter.api.Test;
 import org.springframework.context.annotation.AnnotationConfigApplicationContext;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
+@Tag("unit")
+@Tag("nats")
 class RqueueNatsListenerConfigTest {
 
   @Configuration
