From b2349fd1ea2eb0ea959f53d7f372afebb40a97dc Mon Sep 17 00:00:00 2001 From: Christoph Strobl Date: Wed, 24 Mar 2021 13:44:30 +0100 Subject: [PATCH] Guard tests when no cluster available. See #1711 Original Pull Request: #1977 --- .../DefaultStreamOperationsIntegrationTests.java | 13 +++++++++---- 1 file changed, 9 insertions(+), 4 deletions(-) diff --git a/src/test/java/org/springframework/data/redis/core/DefaultStreamOperationsIntegrationTests.java b/src/test/java/org/springframework/data/redis/core/DefaultStreamOperationsIntegrationTests.java index 6ea5f9456..ccd2c45b6 100644 --- a/src/test/java/org/springframework/data/redis/core/DefaultStreamOperationsIntegrationTests.java +++ b/src/test/java/org/springframework/data/redis/core/DefaultStreamOperationsIntegrationTests.java @@ -46,6 +46,7 @@ import org.springframework.data.redis.connection.stream.StreamReadOptions; import org.springframework.data.redis.connection.stream.StreamRecords; import org.springframework.data.redis.test.condition.EnabledOnCommand; import org.springframework.data.redis.test.condition.EnabledOnRedisDriver; +import org.springframework.data.redis.test.condition.RedisDetector; import org.springframework.data.redis.test.extension.RedisCluster; import org.springframework.data.redis.test.extension.RedisStanalone; import org.springframework.data.redis.test.extension.parametrized.MethodSource; @@ -86,14 +87,18 @@ public class DefaultStreamOperationsIntegrationTests { params.addAll(AbstractOperationsTestParams .testParams(JedisConnectionFactoryExtension.getConnectionFactory(RedisStanalone.class))); - params.addAll(AbstractOperationsTestParams - .testParams(JedisConnectionFactoryExtension.getConnectionFactory(RedisCluster.class))); + if(RedisDetector.isClusterAvailable()) { + params.addAll(AbstractOperationsTestParams + .testParams(JedisConnectionFactoryExtension.getConnectionFactory(RedisCluster.class))); + } params.addAll(AbstractOperationsTestParams .testParams(LettuceConnectionFactoryExtension.getConnectionFactory(RedisStanalone.class))); - params.addAll(AbstractOperationsTestParams - .testParams(LettuceConnectionFactoryExtension.getConnectionFactory(RedisCluster.class))); + if(RedisDetector.isClusterAvailable()) { + params.addAll(AbstractOperationsTestParams + .testParams(LettuceConnectionFactoryExtension.getConnectionFactory(RedisCluster.class))); + } return params; }