Skip to content

Commit f88e3d8

Browse files
committed
fix: resolve RqueueListenerAutoConfigTest transport configuration conflict
The test was configuring both redisConnectionFactory and a non-Redis MessageBroker, which violates the validation in SimpleRqueueListenerContainerFactory that ensures exactly one transport is configured. Fixed by setting the messageBroker directly instead of the Redis connection factory when testing with a non-Redis broker. Assisted-By: Claude Code
1 parent 86df352 commit f88e3d8

2 files changed

Lines changed: 4 additions & 1 deletion

File tree

rqueue-core/src/test/java/com/github/sonus21/rqueue/core/impl/ReactiveRqueueMessageEnqueuerBrokerRoutingTest.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,8 @@
2525
import static org.mockito.Mockito.verify;
2626
import static org.mockito.Mockito.when;
2727

28+
import com.github.sonus21.rqueue.core.spi.Capabilities;
29+
2830
import com.github.sonus21.TestBase;
2931
import com.github.sonus21.rqueue.CoreUnitTest;
3032
import com.github.sonus21.rqueue.config.RqueueConfig;
@@ -92,6 +94,7 @@ void init() throws IllegalAccessException {
9294
FieldUtils.writeField(enqueuer, "rqueueConfig", rqueueConfig, true);
9395
FieldUtils.writeField(
9496
enqueuer, "rqueueMessageMetadataService", rqueueMessageMetadataService, true);
97+
lenient().when(messageBroker.capabilities()).thenReturn(new Capabilities(true, false, false, true));
9598
lenient()
9699
.when(rqueueMessageMetadataService.saveReactive(any(), any(), anyBoolean()))
97100
.thenReturn(Mono.just(Boolean.TRUE));

rqueue-spring-boot-starter/src/test/java/com/github/sonus21/rqueue/spring/boot/tests/unit/RqueueListenerAutoConfigTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -111,7 +111,7 @@ void rqueueMessageListenerContainer()
111111
throws IllegalAccessException, ClassNotFoundException, InstantiationException {
112112
SimpleRqueueListenerContainerFactory factory = new SimpleRqueueListenerContainerFactory();
113113
factory.setMessageConverterProvider(new DefaultMessageConverterProvider());
114-
factory.setRedisConnectionFactory(redisConnectionFactory);
114+
factory.setMessageBroker(messageBroker);
115115
RqueueListenerAutoConfig messageAutoConfig = new RqueueListenerAutoConfig();
116116
FieldUtils.writeField(
117117
messageAutoConfig,

0 commit comments

Comments
 (0)