Limit test to RabbitMQ 4.1.2+

Author: acogoluegnes

src/test/java/com/rabbitmq/stream/impl/RecoveryClusterTest.java

@@ -16,6 +16,7 @@
 
 import static com.rabbitmq.stream.impl.Assertions.assertThat;
 import static com.rabbitmq.stream.impl.LoadBalancerClusterTest.LOAD_BALANCER_ADDRESS;
+import static com.rabbitmq.stream.impl.TestUtils.BrokerVersion.RABBITMQ_4_1_2;
 import static com.rabbitmq.stream.impl.TestUtils.newLoggerLevel;
 import static com.rabbitmq.stream.impl.TestUtils.sync;
 import static com.rabbitmq.stream.impl.TestUtils.waitAtMost;
@@ -30,6 +31,7 @@
 import com.google.common.collect.Streams;
 import com.google.common.util.concurrent.RateLimiter;
 import com.rabbitmq.stream.*;
+import com.rabbitmq.stream.impl.TestUtils.BrokerVersionAtLeast;
 import com.rabbitmq.stream.impl.TestUtils.DisabledIfNotCluster;
 import com.rabbitmq.stream.impl.TestUtils.Sync;
 import com.rabbitmq.stream.impl.Tuples.Pair;
@@ -292,6 +294,7 @@ void clusterRestart(boolean useLoadBalancer, boolean forceLeader) throws Interru
 
   @ParameterizedTest
   @ValueSource(booleans = {true, false})
+  @BrokerVersionAtLeast(RABBITMQ_4_1_2)
   void sacWithClusterRestart(boolean superStream) throws Exception {
     environment =
         environmentBuilder

src/test/java/com/rabbitmq/stream/impl/TestUtils.java

@@ -1064,7 +1064,8 @@ public enum BrokerVersion {
     RABBITMQ_3_11_11("3.11.11"),
     RABBITMQ_3_11_14("3.11.14"),
     RABBITMQ_3_13_0("3.13.0"),
-    RABBITMQ_4_0_0("4.0.0");
+    RABBITMQ_4_0_0("4.0.0"),
+    RABBITMQ_4_1_2("4.1.2");
 
     final String value;