Adapt to AMQP SQL Filter Expressions

Update filter name, operator must be in upper case.

References rabbitmq/rabbitmq-server#14184

Author: acogoluegnes

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

@@ -446,7 +446,7 @@ public StreamFilterOptions sql(String sql) {
         throw new IllegalArgumentException(
             "AMQP SQL filter expressions requires at least RabbitMQ 4.2.0");
       }
-      this.filters.put("sql-filter", filterValue("apache.org:selector-filter:string", sql));
+      this.filters.put("sql-filter", filterValue("amqp:sql-filter", sql));
       return this;
     }
 

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

@@ -544,7 +544,7 @@ void sqlFilterExpressionsShouldFilterMessages() {
     List<Message> msgs = consume(2, m -> m.sql("properties.subject LIKE 'ab%'"));
     msgs.forEach(m -> assertThat(m.subject()).startsWith("ab"));
 
-    msgs = consume(1, m -> m.sql("properties.subject like 'foo%'"));
+    msgs = consume(1, m -> m.sql("properties.subject LIKE 'foo%'"));
     msgs.forEach(m -> assertThat(m).hasSubject("foo bar"));
   }