Reply-to is an address in RabbitMQ 4.2+

References rabbitmq/rabbitmq-server#14474

Author: acogoluegnes

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

@@ -15,7 +15,9 @@
 package com.rabbitmq.stream.impl;
 
 import static com.rabbitmq.stream.impl.TestUtils.*;
+import static com.rabbitmq.stream.impl.TestUtils.BrokerVersion.RABBITMQ_4_2_0;
 import static com.rabbitmq.stream.impl.TestUtils.ResponseConditions.ok;
+import static com.rabbitmq.stream.impl.TestUtils.atLeastVersion;
 import static java.util.Collections.singletonList;
 import static java.util.concurrent.TimeUnit.SECONDS;
 import static org.assertj.core.api.Assertions.assertThat;
@@ -44,11 +46,10 @@
 import java.util.stream.Stream;
 import org.apache.commons.lang3.StringUtils;
 import org.junit.jupiter.api.TestInfo;
-import org.junit.jupiter.api.extension.ExtendWith;
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.MethodSource;
 
-@ExtendWith(TestUtils.StreamTestInfrastructureExtension.class)
+@StreamTestInfrastructure
 public class AmqpInteroperabilityTest {
 
   static final Charset UTF8 = StandardCharsets.UTF_8;
@@ -166,7 +167,10 @@ void publishToStreamQueueConsumeFromStream(Codec codec) throws Exception {
                             .doesNotContainKeys("x-basic-priority")),
                 ptc(
                     b -> b.replyTo("reply to"),
-                    m -> assertThat(m.getProperties().getReplyTo()).isEqualTo("reply to")),
+                    m -> {
+                      String expected = brokerVersion42Ormore() ? "/queues/reply%20to" : "reply to";
+                      assertThat(m.getProperties().getReplyTo()).isEqualTo(expected);
+                    }),
                 ptc(
                     b -> b.timestamp(timestamp),
                     m ->
@@ -682,6 +686,10 @@ void messageWithEmptyBodyAndPropertiesShouldBeConvertedInAmqp(Codec codec) throw
     }
   }
 
+  private boolean brokerVersion42Ormore() {
+    return atLeastVersion(RABBITMQ_4_2_0.version(), brokerVersion);
+  }
+
   private static class PropertiesTestConfiguration {
     final Consumer<AMQP.BasicProperties.Builder> builder;
     final Consumer<Message> assertion;

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

@@ -1095,7 +1095,8 @@ public enum BrokerVersion {
     RABBITMQ_3_13_0("3.13.0"),
     RABBITMQ_4_0_0("4.0.0"),
     RABBITMQ_4_1_2("4.1.2"),
-    RABBITMQ_4_1_4("4.1.4");
+    RABBITMQ_4_1_4("4.1.4"),
+    RABBITMQ_4_2_0("4.2.0");
 
     final String value;