Test x-modulus-hash exchange creation if it is available

RabbitMQ 4.3+.

References rabbitmq/rabbitmq-server#15849
References #1918

Author: acogoluegnes

src/test/java/com/rabbitmq/client/test/TestUtils.java

@@ -194,6 +194,10 @@ public static boolean isVersion310orLater(Connection connection) {
     return atLeastVersion("3.10.0", connection);
   }
 
+  public static boolean isVersion43orLater(Connection connection) {
+    return atLeastVersion("4.3.0", connection);
+  }
+
   private static boolean atLeastVersion(String expectedVersion, Connection connection) {
     return atLeastVersion(
         expectedVersion,

src/test/java/com/rabbitmq/client/test/functional/ExchangeDeclare.java

@@ -19,6 +19,7 @@
 import static org.junit.jupiter.api.Assertions.assertEquals;
 
 import java.io.IOException;
+import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.HashMap;
 import java.util.List;
@@ -85,11 +86,11 @@ public void releaseResources() throws IOException {
         verifyNotEquivalent(NAME, "direct", false, true, null);
     }
 
-    @Test public void exchangeDeclaredWithEnumerationEquivalentOnNonRecoverableConnection() throws IOException, InterruptedException {
+    @Test public void exchangeDeclaredWithEnumerationEquivalentOnNonRecoverableConnection() throws IOException {
         doTestExchangeDeclaredWithEnumerationEquivalent(channel);
     }
 
-    @Test public void exchangeDeclaredWithEnumerationEquivalentOnRecoverableConnection() throws IOException, TimeoutException, InterruptedException {
+    @Test public void exchangeDeclaredWithEnumerationEquivalentOnRecoverableConnection() throws IOException, TimeoutException {
         ConnectionFactory connectionFactory = TestUtils.connectionFactory();
         connectionFactory.setAutomaticRecoveryEnabled(true);
         connectionFactory.setTopologyRecoveryEnabled(false);
@@ -102,13 +103,17 @@ public void releaseResources() throws IOException {
 
     }
 
-    private void doTestExchangeDeclaredWithEnumerationEquivalent(Channel channel) throws IOException, InterruptedException {
+    private void doTestExchangeDeclaredWithEnumerationEquivalent(Channel channel) throws IOException {
         // Only test AMQP 0-9-1 standard types; plugin and newer core types
         // (e.g. x-modulus-hash, x-local-random) may not be available on the test broker
         List<BuiltinExchangeType> standardTypes = Arrays.asList(
             BuiltinExchangeType.DIRECT, BuiltinExchangeType.FANOUT,
             BuiltinExchangeType.TOPIC, BuiltinExchangeType.HEADERS
         );
+        if (TestUtils.isVersion43orLater(channel.getConnection())) {
+           standardTypes = new ArrayList<>(standardTypes);
+           standardTypes.add(BuiltinExchangeType.MODULUS_HASH);
+        }
         for (BuiltinExchangeType exchangeType : standardTypes) {
             channel.exchangeDeclare(NAME, exchangeType);
             verifyEquivalent(NAME, exchangeType.getType(), false, false, null);