Enable some TLS tests only from Java 11

They fail on Java 8-9-10 on Ubuntu 22.04, possibly because
the OS makes TLS gen uses algorithm that "old" JRE do not
support. This is acceptable if we want to test against
latest environments.

(cherry picked from commit ba9316d)

Author: acogoluegnes

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

@@ -331,7 +331,6 @@ public void evaluate() throws Throwable {
 
     private static class BrokerIsNotOnDocker implements TestRule {
 
-
         @Override
         public Statement apply(Statement base, Description description) {
             return new Statement() {
@@ -465,4 +464,67 @@ public void evaluate() throws Throwable {
             };
         }
     }
+
+    public static TestRule atLeastJava11() {
+        return new AtLeastJavaVersion(11);
+    }
+
+    private static class AtLeastJavaVersion implements TestRule {
+
+        private final int expectedMinVersion;
+
+        private AtLeastJavaVersion(int expectedMinVersion) {
+            this.expectedMinVersion = expectedMinVersion;
+        }
+
+        @Override
+        public Statement apply(Statement base, Description description) {
+            return new Statement() {
+                @Override
+                public void evaluate() throws Throwable {
+                    try {
+                        int javaMajorVersion = javaMajorVersion();
+                        if (javaMajorVersion < expectedMinVersion) {
+                            throw new AssumptionViolatedException("Java version is " + javaMajorVersion
+                                + ", expecting at least " + expectedMinVersion);
+                        }
+                    } catch (AssumptionViolatedException e) {
+                        throw e;
+                    } catch (Exception e) {
+                        throw new AssumptionViolatedException("Could determine Java version", e);
+                    }
+                    base.evaluate();
+                }
+            };
+        }
+    }
+
+    private static int javaMajorVersion() {
+        String javaVersion = System.getProperty("java.version");
+        if (javaVersion == null || javaVersion.trim().isEmpty()) {
+            throw new IllegalStateException("JVM system property 'java.version' is undefined");
+        }
+
+        if (javaVersion.startsWith("1.8")) {
+            return 8;
+        }
+
+        try {
+            // from JUnit 5 JRE class
+            // java.lang.Runtime.version() is a static method available on Java 9+
+            // that returns an instance of java.lang.Runtime.Version which has the
+            // following method: public int major()
+            Method versionMethod = Runtime.class.getMethod("version");
+            Object version = versionMethod.invoke(null);
+            Method majorMethod = version.getClass().getMethod("major");
+            int major = (int) majorMethod.invoke(version);
+            if (major < 9) {
+                throw new IllegalStateException("Invalid Java major version: " + major);
+            }
+            return major;
+        } catch (Exception ex) {
+            LOGGER.warn("Error while computing Java major version", ex);
+        }
+        throw new IllegalStateException("Could not determine Java major version");
+    }
 }

src/test/java/com/rabbitmq/client/test/ssl/BadVerifiedConnection.java

@@ -1,4 +1,4 @@
-// Copyright (c) 2007-2021 VMware, Inc. or its affiliates.  All rights reserved.
+// Copyright (c) 2007-2022 VMware, Inc. or its affiliates.  All rights reserved.
 //
 // This software, the RabbitMQ Java client library, is triple-licensed under the
 // Mozilla Public License 2.0 ("MPL"), the GNU General Public License version 2
@@ -15,12 +15,15 @@
 
 package com.rabbitmq.client.test.ssl;
 
+import com.rabbitmq.client.test.TestUtils;
+import org.junit.ClassRule;
 import org.junit.Test;
 
 import javax.net.ssl.SSLContext;
 import javax.net.ssl.SSLHandshakeException;
 import java.io.IOException;
 import java.util.concurrent.TimeoutException;
+import org.junit.rules.TestRule;
 
 import static org.junit.Assert.fail;
 
@@ -29,6 +32,10 @@
  *
  */
 public class BadVerifiedConnection extends UnverifiedConnection {
+
+    @ClassRule
+    public static TestRule atLeastJava11TestRule = TestUtils.atLeastJava11();
+
     public void openConnection()
             throws IOException, TimeoutException {
         try {

src/test/java/com/rabbitmq/client/test/ssl/HostnameVerification.java

@@ -1,4 +1,4 @@
-// Copyright (c) 2007-2021 VMware, Inc. or its affiliates.  All rights reserved.
+// Copyright (c) 2007-2022 VMware, Inc. or its affiliates.  All rights reserved.
 //
 // This software, the RabbitMQ Java client library, is triple-licensed under the
 // Mozilla Public License 2.0 ("MPL"), the GNU General Public License version 2
@@ -20,7 +20,9 @@
 import com.rabbitmq.client.ConnectionFactory;
 import com.rabbitmq.client.test.TestUtils;
 import org.junit.BeforeClass;
+import org.junit.ClassRule;
 import org.junit.Test;
+import org.junit.rules.TestRule;
 import org.junit.runner.RunWith;
 import org.junit.runners.Parameterized;
 
@@ -35,6 +37,9 @@
 @RunWith(Parameterized.class)
 public class HostnameVerification {
 
+    @ClassRule
+    public static TestRule atLeastJava11TestRule = TestUtils.atLeastJava11();
+
     static SSLContext sslContext;
     @Parameterized.Parameter
     public Consumer<ConnectionFactory> customizer;

src/test/java/com/rabbitmq/client/test/ssl/VerifiedConnection.java

@@ -1,4 +1,4 @@
-// Copyright (c) 2007-2021 VMware, Inc. or its affiliates.  All rights reserved.
+// Copyright (c) 2007-2022 VMware, Inc. or its affiliates.  All rights reserved.
 //
 // This software, the RabbitMQ Java client library, is triple-licensed under the
 // Mozilla Public License 2.0 ("MPL"), the GNU General Public License version 2
@@ -36,7 +36,9 @@
 
 import com.rabbitmq.client.ConnectionFactory;
 import com.rabbitmq.client.test.TestUtils;
+import org.junit.ClassRule;
 import org.junit.Test;
+import org.junit.rules.TestRule;
 import org.slf4j.LoggerFactory;
 
 /**
@@ -45,6 +47,9 @@
  */
 public class VerifiedConnection extends UnverifiedConnection {
 
+    @ClassRule
+    public static TestRule atLeastJava11TestRule = TestUtils.atLeastJava11();
+
     public void openConnection()
             throws IOException, TimeoutException {
         try {