Start an embedded Redis in NatsBackendEndToEndIT

The dashboard controller chain (RqueueRestController → RqueueDashboardChartServiceImpl
→ RqueueQStatsDaoImpl → RqueueConfig) currently still hard-requires a
RedisConnectionFactory bean even when rqueue.backend=nats, so excluding
DataRedisAutoConfiguration left the Spring context unable to load on the CI
runner.

Until those beans are made conditional on the broker's
usesPrimaryHandlerDispatch capability (tracked as a v1.x follow-up), this
e2e test starts an embedded Redis on a free port purely to satisfy the
bean graph. The actual produce-and-consume flow runs entirely through
JetStream — Redis is never touched by the message path.

Assisted-By: Claude Code

Author: sonus21

rqueue-spring-boot-starter/src/test/java/com/github/sonus21/rqueue/spring/boot/integration/NatsBackendEndToEndIT.java

@@ -19,17 +19,18 @@
 
 import com.github.sonus21.rqueue.annotation.RqueueListener;
 import com.github.sonus21.rqueue.core.RqueueMessageEnqueuer;
+import java.net.ServerSocket;
 import java.util.ArrayList;
 import java.util.Collections;
 import java.util.List;
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.TimeUnit;
+import org.junit.jupiter.api.AfterAll;
+import org.junit.jupiter.api.BeforeAll;
 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;
-import org.springframework.boot.data.redis.autoconfigure.DataRedisAutoConfiguration;
-import org.springframework.boot.data.redis.autoconfigure.DataRedisReactiveAutoConfiguration;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.stereotype.Component;
 import org.springframework.test.context.DynamicPropertyRegistry;
@@ -39,6 +40,7 @@
 import org.testcontainers.junit.jupiter.Container;
 import org.testcontainers.junit.jupiter.Testcontainers;
 import org.testcontainers.utility.DockerImageName;
+import redis.embedded.RedisServer;
 
 /**
  * End-to-end integration test wiring a Spring Boot application against a Testcontainers-managed
@@ -50,21 +52,14 @@
  *           -> BrokerMessagePoller.pop -> @RqueueListener invocation -> broker.ack
  * </pre>
  *
- * <h2>Why Redis auto-config is excluded</h2>
+ * <h2>Why an embedded Redis is started</h2>
  *
- * The starter declares {@code spring-boot-starter-data-redis} as an {@code api} dependency, so
- * Spring Boot would try to auto-configure a {@code LettuceConnectionFactory} at startup and fail
- * the context because no Redis instance is available in this test. Excluding the Redis
- * auto-config classes on {@link TestApp} (rather than via property) keeps the exclusion local to
- * this test and visible to readers.
- *
- * <h2>Producer path</h2>
- *
- * The sync producer flows through {@code BaseMessageSender#enqueue} which now delegates to
- * {@code MessageBroker.enqueue(QueueDetail, RqueueMessage)} when the active broker advertises
- * {@code !usesPrimaryHandlerDispatch()}, and {@code storeMessageMetadata} short-circuits on the
- * same flag so no Redis HASH write is attempted. Together with the broker-driven poller this
- * exercises the full produce-and-consume loop without touching Redis.
+ * Several rqueue beans (notably {@code RqueueConfig}, {@code RqueueQStatsDaoImpl}, and the
+ * dashboard controller chain) currently still require a {@code RedisConnectionFactory} as a hard
+ * Spring dependency, even when {@code rqueue.backend=nats}. Pure NATS-only deployments without
+ * Redis on the classpath will need those beans to become conditional — tracked as a v1.x
+ * follow-up. Until then this test starts an embedded Redis purely to satisfy the bean graph;
+ * the actual message flow runs entirely through JetStream and never hits Redis.
  */
 @SpringBootTest(
     classes = NatsBackendEndToEndIT.TestApp.class,
@@ -73,25 +68,43 @@
 @Tag("nats")
 class NatsBackendEndToEndIT {
 
+  private static RedisServer REDIS;
+  private static int REDIS_PORT;
+
   @Container
-  static final GenericContainer<?> NATS = new GenericContainer<>(
-          DockerImageName.parse("nats:2.10-alpine"))
-      .withCommand("-js")
-      .withExposedPorts(4222)
-      .waitingFor(Wait.forLogMessage(".*Server is ready.*\\n", 1));
+  static final GenericContainer<?> NATS =
+      new GenericContainer<>(DockerImageName.parse("nats:2.10-alpine"))
+          .withCommand("-js")
+          .withExposedPorts(4222)
+          .waitingFor(Wait.forLogMessage(".*Server is ready.*\\n", 1));
+
+  @BeforeAll
+  static void startRedis() throws Exception {
+    try (ServerSocket s = new ServerSocket(0)) {
+      REDIS_PORT = s.getLocalPort();
+    }
+    REDIS = new RedisServer(REDIS_PORT);
+    REDIS.start();
+  }
+
+  @AfterAll
+  static void stopRedis() throws Exception {
+    if (REDIS != null) {
+      REDIS.stop();
+    }
+  }
 
   @DynamicPropertySource
-  static void natsProps(DynamicPropertyRegistry r) {
+  static void registerProps(DynamicPropertyRegistry r) {
     r.add(
         "rqueue.nats.connection.url",
         () -> "nats://" + NATS.getHost() + ":" + NATS.getMappedPort(4222));
+    r.add("spring.data.redis.host", () -> "localhost");
+    r.add("spring.data.redis.port", () -> REDIS_PORT);
   }
 
-  @Autowired
-  RqueueMessageEnqueuer enqueuer;
-
-  @Autowired
-  TestListener listener;
+  @Autowired RqueueMessageEnqueuer enqueuer;
+  @Autowired TestListener listener;
 
   @Test
   void enqueueIsReceivedByListener() throws Exception {
@@ -103,8 +116,7 @@ void enqueueIsReceivedByListener() throws Exception {
         .containsExactlyInAnyOrder("payload-0", "payload-1", "payload-2", "payload-3", "payload-4");
   }
 
-  @SpringBootApplication(
-      exclude = {DataRedisAutoConfiguration.class, DataRedisReactiveAutoConfiguration.class})
+  @SpringBootApplication
   static class TestApp {}
 
   @Component