Test SQL filter expressions against RabbitMQ 4.2

Author: acogoluegnes

.github/workflows/test-pr.yml

@@ -24,8 +24,6 @@ jobs:
           cache: 'maven'
       - name: Start broker
         run: ci/start-broker.sh
-        env:
-          RABBITMQ_IMAGE: pivotalrabbitmq/rabbitmq:pr-14110-otp27
       - name: Start toxiproxy
         run: ci/start-toxiproxy.sh
       - name: Display Java version

src/main/java/com/rabbitmq/client/amqp/impl/Utils.java

@@ -263,8 +263,7 @@ static boolean supportSetToken(String brokerVersion) {
   }
 
   static boolean supportSqlFilterExpressions(String brokerVersion) {
-    // TODO should be 4.2
-    return is4_1_OrMore(brokerVersion);
+    return is4_2_OrMore(brokerVersion);
   }
 
   static final class ObservationConnectionInfo implements ObservationCollector.ConnectionInfo {

src/test/java/com/rabbitmq/client/amqp/impl/SourceFiltersTest.java

@@ -21,6 +21,7 @@
 import static com.rabbitmq.client.amqp.Management.QueueType.STREAM;
 import static com.rabbitmq.client.amqp.impl.Assertions.assertThat;
 import static com.rabbitmq.client.amqp.impl.TestConditions.BrokerVersion.RABBITMQ_4_1_0;
+import static com.rabbitmq.client.amqp.impl.TestConditions.BrokerVersion.RABBITMQ_4_2_0;
 import static com.rabbitmq.client.amqp.impl.TestUtils.sync;
 import static com.rabbitmq.client.amqp.impl.TestUtils.waitUntilStable;
 import static java.nio.charset.StandardCharsets.*;
@@ -471,8 +472,7 @@ void filterExpressionStringModifier() {
   }
 
   @Test
-  // TODO should be 4.2
-  @BrokerVersionAtLeast(RABBITMQ_4_1_0)
+  @BrokerVersionAtLeast(RABBITMQ_4_2_0)
   void sqlFilterExpressionsShouldFilterMessages() {
     publish(1, m -> m.subject("abc 123"));
     publish(1, m -> m.subject("foo bar"));
@@ -486,8 +486,7 @@ void sqlFilterExpressionsShouldFilterMessages() {
   }
 
   @Test
-  // TODO should be 4.2
-  @BrokerVersionAtLeast(RABBITMQ_4_1_0)
+  @BrokerVersionAtLeast(RABBITMQ_4_2_0)
   void incorrectFilterShouldThrowException() {
     assertThatThrownBy(
             () ->