Gate Redis-only beans on rqueue.backend; drop embedded Redis from e2e

Applies @conditional(RedisBackendCondition.class) to every Redis-shaped
bean in rqueue-core so they stay out of the context when
rqueue.backend=nats:

  - @bean factories in RqueueListenerBaseConfig: rqueueRedisLongTemplate,
    rqueueRedisListenerContainerFactory, scheduledMessageScheduler,
    processingMessageScheduler, stringRqueueRedisTemplate, rqueueStringDao,
    rqueueWorkerRegistry, rqueueLockManager, rqueueQueueMetrics,
    rqueueInternalPubSubChannel.
  - @repository / @service / @controller types: RqueueQStatsDaoImpl,
    RqueueJobDaoImpl, RqueueMessageMetadataDaoImpl, RqueueSystemConfigDaoImpl,
    RqueueDashboardChartServiceImpl, RqueueJobServiceImpl,
    RqueueMessageMetadataServiceImpl, RqueueQDetailServiceImpl,
    RqueueSystemManagerServiceImpl, RqueueUtilityServiceImpl,
    RqueueViewControllerServiceImpl, RqueueRestController,
    ReactiveRqueueRestController, RqueueViewController,
    ReactiveRqueueViewController. The four controllers compose the new
    condition with their existing Reactive(Enabled|Disabled) guard via
    @conditional({RedisBackendCondition.class, ReactiveDisabled.class}).

BaseMessageSender now autowires its Redis-shaped collaborators
(RqueueStringDao, RqueueMessageMetadataService) with required=false; the
producer methods that touch them already short-circuit on the broker
capability flag, so a null reference is safe on the NATS path.

NatsBackendEndToEndIT no longer needs an embedded Redis to satisfy the
Spring bean graph and reverts to excluding DataRedisAutoConfiguration so
the test boots truly Redis-free.

Adds .claude/ to .gitignore so agent worktrees don't end up tracked.

Assisted-By: Claude Code

Author: sonus21

.gitignore

@@ -32,4 +32,4 @@ hs_err_pid*
 /*/build/
 /*/log
 
-.DS_Store
+.DS_Store.claude/

rqueue-core/src/main/java/com/github/sonus21/rqueue/config/RqueueListenerBaseConfig.java

@@ -207,11 +207,13 @@ protected RqueueMessageTemplate getMessageTemplate(RqueueConfig rqueueConfig) {
   }
 
   @Bean
+  @Conditional(RedisBackendCondition.class)
   public RedisTemplate<String, Long> rqueueRedisLongTemplate(RqueueConfig rqueueConfig) {
     return getRedisTemplate(rqueueConfig.getConnectionFactory());
   }
 
   @Bean
+  @Conditional(RedisBackendCondition.class)
   public RqueueRedisListenerContainerFactory rqueueRedisListenerContainerFactory() {
     return new RqueueRedisListenerContainerFactory();
   }
@@ -223,6 +225,7 @@ public RqueueRedisListenerContainerFactory rqueueRedisListenerContainerFactory()
    * @return {@link ScheduledQueueMessageScheduler} object
    */
   @Bean
+  @Conditional(RedisBackendCondition.class)
   public ScheduledQueueMessageScheduler scheduledMessageScheduler() {
     return new ScheduledQueueMessageScheduler();
   }
@@ -234,26 +237,31 @@ public ScheduledQueueMessageScheduler scheduledMessageScheduler() {
    * @return {@link ProcessingQueueMessageScheduler} object
    */
   @Bean
+  @Conditional(RedisBackendCondition.class)
   public ProcessingQueueMessageScheduler processingMessageScheduler() {
     return new ProcessingQueueMessageScheduler();
   }
 
   @Bean
+  @Conditional(RedisBackendCondition.class)
   public RqueueRedisTemplate<String> stringRqueueRedisTemplate(RqueueConfig rqueueConfig) {
     return new RqueueRedisTemplate<>(rqueueConfig.getConnectionFactory());
   }
 
   @Bean
+  @Conditional(RedisBackendCondition.class)
   public RqueueStringDao rqueueStringDao(RqueueConfig rqueueConfig) {
     return new RqueueStringDaoImpl(rqueueConfig);
   }
 
   @Bean
+  @Conditional(RedisBackendCondition.class)
   public RqueueWorkerRegistry rqueueWorkerRegistry(RqueueConfig rqueueConfig) {
     return new RqueueWorkerRegistryImpl(rqueueConfig);
   }
 
   @Bean
+  @Conditional(RedisBackendCondition.class)
   public RqueueLockManager rqueueLockManager(RqueueStringDao rqueueStringDao) {
     return new RqueueLockManagerImpl(rqueueStringDao);
   }
@@ -286,6 +294,7 @@ public org.springframework.web.reactive.result.view.ViewResolver reactiveRqueueV
   }
 
   @Bean
+  @Conditional(RedisBackendCondition.class)
   public RqueueQueueMetrics rqueueQueueMetrics(
       RqueueRedisTemplate<String> stringRqueueRedisTemplate) {
     return new RqueueQueueMetrics(stringRqueueRedisTemplate);
@@ -297,6 +306,7 @@ public RqueueBeanProvider rqueueBeanProvider() {
   }
 
   @Bean
+  @Conditional(RedisBackendCondition.class)
   public RqueueInternalPubSubChannel rqueueInternalPubSubChannel(
       RqueueRedisListenerContainerFactory rqueueRedisListenerContainerFactory,
       RqueueMessageListenerContainer rqueueMessageListenerContainer,

rqueue-core/src/main/java/com/github/sonus21/rqueue/core/impl/BaseMessageSender.java

@@ -54,13 +54,15 @@ abstract class BaseMessageSender {
   protected final RqueueMessageTemplate messageTemplate;
   protected final RqueueMessageIdGenerator messageIdGenerator;
 
-  @Autowired
+  // Redis-only collaborators — absent when rqueue.backend=nats. Methods that touch them
+  // already short-circuit on the broker capability flag, so a null is safe.
+  @Autowired(required = false)
   protected RqueueStringDao rqueueStringDao;
 
   @Autowired
   protected RqueueConfig rqueueConfig;
 
-  @Autowired
+  @Autowired(required = false)
   protected RqueueMessageMetadataService rqueueMessageMetadataService;
 
   BaseMessageSender(

rqueue-core/src/main/java/com/github/sonus21/rqueue/dao/impl/RqueueJobDaoImpl.java

@@ -16,6 +16,9 @@
 
 package com.github.sonus21.rqueue.dao.impl;
 
+import com.github.sonus21.rqueue.config.RedisBackendCondition;
+import org.springframework.context.annotation.Conditional;
+
 import com.github.sonus21.rqueue.common.RqueueRedisTemplate;
 import com.github.sonus21.rqueue.config.RqueueConfig;
 import com.github.sonus21.rqueue.dao.RqueueJobDao;
@@ -32,6 +35,7 @@
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Repository;
 
+@Conditional(RedisBackendCondition.class)
 @Repository
 public class RqueueJobDaoImpl implements RqueueJobDao {
 

rqueue-core/src/main/java/com/github/sonus21/rqueue/dao/impl/RqueueMessageMetadataDaoImpl.java

@@ -16,6 +16,9 @@
 
 package com.github.sonus21.rqueue.dao.impl;
 
+import com.github.sonus21.rqueue.config.RedisBackendCondition;
+import org.springframework.context.annotation.Conditional;
+
 import com.github.sonus21.rqueue.common.ReactiveRqueueRedisTemplate;
 import com.github.sonus21.rqueue.common.RqueueRedisTemplate;
 import com.github.sonus21.rqueue.config.RqueueConfig;
@@ -31,6 +34,7 @@
 import org.springframework.util.Assert;
 import reactor.core.publisher.Mono;
 
+@Conditional(RedisBackendCondition.class)
 @Repository
 public class RqueueMessageMetadataDaoImpl implements RqueueMessageMetadataDao {
 

rqueue-core/src/main/java/com/github/sonus21/rqueue/dao/impl/RqueueQStatsDaoImpl.java

@@ -16,6 +16,9 @@
 
 package com.github.sonus21.rqueue.dao.impl;
 
+import com.github.sonus21.rqueue.config.RedisBackendCondition;
+import org.springframework.context.annotation.Conditional;
+
 import com.github.sonus21.rqueue.common.RqueueRedisTemplate;
 import com.github.sonus21.rqueue.config.RqueueConfig;
 import com.github.sonus21.rqueue.dao.RqueueQStatsDao;
@@ -27,6 +30,7 @@
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Repository;
 
+@Conditional(RedisBackendCondition.class)
 @Repository
 public class RqueueQStatsDaoImpl implements RqueueQStatsDao {
 

rqueue-core/src/main/java/com/github/sonus21/rqueue/dao/impl/RqueueSystemConfigDaoImpl.java

@@ -16,6 +16,9 @@
 
 package com.github.sonus21.rqueue.dao.impl;
 
+import com.github.sonus21.rqueue.config.RedisBackendCondition;
+import org.springframework.context.annotation.Conditional;
+
 import com.github.sonus21.rqueue.common.RqueueRedisTemplate;
 import com.github.sonus21.rqueue.config.RqueueConfig;
 import com.github.sonus21.rqueue.dao.RqueueSystemConfigDao;
@@ -32,6 +35,7 @@
 import org.springframework.stereotype.Repository;
 import org.springframework.util.CollectionUtils;
 
+@Conditional(RedisBackendCondition.class)
 @Repository
 public class RqueueSystemConfigDaoImpl implements RqueueSystemConfigDao {
 

rqueue-core/src/main/java/com/github/sonus21/rqueue/web/controller/ReactiveRqueueRestController.java

@@ -16,6 +16,9 @@
 
 package com.github.sonus21.rqueue.web.controller;
 
+import com.github.sonus21.rqueue.config.RedisBackendCondition;
+import org.springframework.context.annotation.Conditional;
+
 import com.github.sonus21.rqueue.config.RqueueWebConfig;
 import com.github.sonus21.rqueue.exception.ProcessingException;
 import com.github.sonus21.rqueue.models.enums.AggregationType;
@@ -55,8 +58,9 @@
 import org.springframework.web.bind.annotation.RestController;
 import reactor.core.publisher.Mono;
 
+@Conditional({RedisBackendCondition.class, ReactiveEnabled.class})
 @RestController
-@Conditional(ReactiveEnabled.class)
+
 @RequestMapping(path = "${rqueue.web.url.prefix:}rqueue/api/v1")
 public class ReactiveRqueueRestController extends BaseReactiveController {
 

rqueue-core/src/main/java/com/github/sonus21/rqueue/web/controller/ReactiveRqueueViewController.java

@@ -16,6 +16,9 @@
 
 package com.github.sonus21.rqueue.web.controller;
 
+import com.github.sonus21.rqueue.config.RedisBackendCondition;
+import org.springframework.context.annotation.Conditional;
+
 import com.github.sonus21.rqueue.config.RqueueWebConfig;
 import com.github.sonus21.rqueue.utils.condition.ReactiveEnabled;
 import com.github.sonus21.rqueue.web.service.RqueueViewControllerService;
@@ -35,9 +38,10 @@
 import org.springframework.web.reactive.result.view.ViewResolver;
 import reactor.core.publisher.Mono;
 
+@Conditional({RedisBackendCondition.class, ReactiveEnabled.class})
 @Controller
 @RequestMapping(path = "${rqueue.web.url.prefix:}rqueue")
-@Conditional(ReactiveEnabled.class)
+
 public class ReactiveRqueueViewController extends BaseReactiveController {
 
   private final ViewResolver rqueueViewResolver;

rqueue-core/src/main/java/com/github/sonus21/rqueue/web/controller/RqueueRestController.java

@@ -16,6 +16,9 @@
 
 package com.github.sonus21.rqueue.web.controller;
 
+import com.github.sonus21.rqueue.config.RedisBackendCondition;
+import org.springframework.context.annotation.Conditional;
+
 import com.github.sonus21.rqueue.config.RqueueWebConfig;
 import com.github.sonus21.rqueue.exception.ProcessingException;
 import com.github.sonus21.rqueue.models.enums.AggregationType;
@@ -54,9 +57,9 @@
 import org.springframework.web.bind.annotation.ResponseBody;
 import org.springframework.web.bind.annotation.RestController;
 
+@Conditional({RedisBackendCondition.class, ReactiveDisabled.class})
 @RestController
 @RequestMapping(path = "${rqueue.web.url.prefix:}rqueue/api/v1")
-@Conditional(ReactiveDisabled.class)
 public class RqueueRestController extends BaseController {
 
   private final RqueueDashboardChartService rqueueDashboardChartService;