feat: Support Java 25 for API ML v3.x.x — GH#4727

.github/workflows/service-registration.yml

@@ -18,13 +18,19 @@ jobs:
     BuildAndTest:
         runs-on: ubuntu-latest
         timeout-minutes: 35
+        strategy:
+            fail-fast: false
+            matrix:
+                javaVersion: ['17', '21', '25']
 
         steps:
             -   uses: actions/checkout@v4
                 with:
                     ref: ${{ github.head_ref }}
 
             -   uses: ./.github/actions/setup
+                with:
+                    jdkVersion: ${{ matrix.javaVersion }}
 
             -   name: Install BATS to test the shell scripts
                 run: |

apiml-common/src/testFixtures/java/org/zowe/apiml/util/TestLogger.java

@@ -13,9 +13,9 @@
 import ch.qos.logback.classic.spi.ILoggingEvent;
 import ch.qos.logback.core.AppenderBase;
 
-import java.util.LinkedList;
 import java.util.List;
 import java.util.Optional;
+import java.util.concurrent.CopyOnWriteArrayList;
 import java.util.concurrent.atomic.AtomicReference;
 import java.util.function.Predicate;
 
@@ -31,7 +31,7 @@ public TestLogger() {
             listening = lastInstance.get().listening;
             records = lastInstance.get().records;
         } else {
-            records = new LinkedList<>();
+            records = new CopyOnWriteArrayList<>();
         }
         lastInstance.set(this);
     }

codequality/checkstyle/suppressions.xml

@@ -6,4 +6,7 @@
     <suppress checks="MethodName"
               files=".*security-module.*"
     />
+    <suppress checks="IllegalImport"
+              files=".*RefreshablePeerEurekaNodesTest\.java"
+    />
 </suppressions>

discovery-service/src/test/java/org/zowe/apiml/discovery/ApimlInstanceRegistryTest.java

@@ -34,11 +34,13 @@
 import org.zowe.apiml.discovery.config.EurekaConfig;
 import org.zowe.apiml.discovery.metadata.MetadataFilterService;
 
-import java.lang.invoke.MethodHandle;
+import java.lang.invoke.MethodHandles;
+import java.lang.invoke.MethodType;
 import java.util.HashMap;
 import java.util.Map;
 import java.util.Set;
 import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.atomic.AtomicInteger;
 import java.util.stream.Stream;
 
 import static org.junit.jupiter.api.Assertions.*;
@@ -49,6 +51,19 @@
 @ExtendWith(MockitoExtension.class)
 class ApimlInstanceRegistryTest {
 
+    /** Call counter for the test MethodHandle stub — replaces mock(MethodHandle.class) verify. */
+    static final AtomicInteger REPLICATE_CALL_COUNT = new AtomicInteger(0);
+
+    /**
+     * No-op stub for replicateToPeers that records invocations.
+     * Used to create a real MethodHandle via {@code MethodHandles.lookup().findStatic()}
+     * instead of {@code mock(MethodHandle.class)} which fails on Java 25 where MethodHandle is sealed.
+     */
+    static Object replicateToPeersTestStub(Object... args) {
+        REPLICATE_CALL_COUNT.incrementAndGet();
+        return null;
+    }
+
     private ApimlInstanceRegistry apimlInstanceRegistry;
 
     @Mock private EurekaClientConfig clientConfig;
@@ -244,7 +259,9 @@
         @Test
         @SuppressWarnings("unchecked")
         void givenStaticRegistration_thenSuccessful() throws Throwable {
-            var methodHandle = mock(MethodHandle.class);
+            var methodHandle = MethodHandles.lookup().findStatic(
+                ApimlInstanceRegistryTest.class, "replicateToPeersTestStub",
+                MethodType.methodType(Object.class, Object[].class));
             ReflectionTestUtils.setField(apimlInstanceRegistry, "replicateToPeersMethodHandle", methodHandle);
             var currentStaticIds = (Set<String>) ReflectionTestUtils.getField(apimlInstanceRegistry, "staticRegistrationIds");
             assertTrue(currentStaticIds.isEmpty());
@@ -254,7 +271,6 @@
 
             Map<String, Lease<InstanceInfo>> leaseMap = new HashMap<>();
             when(registry.get(anyString())).thenReturn(leaseMap);
-            doReturn(new Object()).when(methodHandle).invokeWithArguments(any(), any(), any(), any(), any(), any(), any());
 
             apimlInstanceRegistry.registerStatically(standardInstance, false, true);
 
@@ -307,13 +323,15 @@
 
         @Test
         void givenPeerReplicaHeartbeat_thenSuccess() throws Throwable {
-            var methodHandle = mock(MethodHandle.class);
+            REPLICATE_CALL_COUNT.set(0);
+            var methodHandle = MethodHandles.lookup().findStatic(
+                ApimlInstanceRegistryTest.class, "replicateToPeersTestStub",
+                MethodType.methodType(Object.class, Object[].class));
             ReflectionTestUtils.setField(apimlInstanceRegistry, "replicateToPeersMethodHandle", methodHandle);
             var instance = mock(InstanceInfo.class);
-            doReturn(new Object()).when(methodHandle).invokeWithArguments(any(), any(), any(), any(), any(), any(), any());
             apimlInstanceRegistry.peerAwareHeartbeat(instance);
 
-            verify(methodHandle, times(1)).invokeWithArguments(any(), any(), any(), any(), any(), any(), any());
+            assertEquals(1, REPLICATE_CALL_COUNT.get());
         }
 
     }

discovery-service/src/test/java/org/zowe/apiml/discovery/eureka/RefreshablePeerEurekaNodesTest.java

@@ -31,10 +31,7 @@
 import org.zowe.apiml.product.eureka.client.ApimlPeerEurekaNode;
 
 import javax.net.ssl.SSLContext;
-import java.lang.invoke.MethodHandles;
-import java.lang.invoke.VarHandle;
 import java.lang.reflect.Field;
-import java.lang.reflect.Modifier;
 import java.security.NoSuchAlgorithmException;
 import java.util.ArrayList;
 import java.util.HashSet;
@@ -43,6 +40,8 @@
 import java.util.concurrent.Executors;
 import java.util.stream.Stream;
 
+import sun.misc.Unsafe;
+
 import static org.junit.jupiter.api.Assertions.*;
 import static org.mockito.Mockito.doReturn;
 import static org.mockito.Mockito.when;
@@ -52,16 +51,6 @@
 class RefreshablePeerEurekaNodesTest {
 
     private static final int DEFAULT_MAX_RETRIES = 10;
-    private static final VarHandle MODIFIERS;
-
-    static {
-        try {
-            var lookup = MethodHandles.privateLookupIn(Field.class, MethodHandles.lookup());
-            MODIFIERS = lookup.findVarHandle(Field.class, "modifiers", int.class);
-        } catch (IllegalAccessException | NoSuchFieldException ex) {
-            throw new RuntimeException(ex);
-        }
-    }
 
     PeerAwareInstanceRegistry registry;
     @Mock
@@ -95,10 +84,13 @@ void givenEurekaNodeUrl_thenCreateNode() throws NoSuchFieldException, SecurityEx
         when(serverConfig.getPeerNodeTotalConnections()).thenReturn(100);
         when(serverConfig.getPeerNodeTotalConnectionsPerHost()).thenReturn(10);
 
-        Field defaultExecutor = StatsMonitor.class.getDeclaredField("DEFAULT_EXECUTOR");
-        MODIFIERS.set(defaultExecutor, defaultExecutor.getModifiers() & ~Modifier.FINAL);
-        defaultExecutor.setAccessible(true);
-        defaultExecutor.set(null, Executors.newSingleThreadScheduledExecutor());
+        Field defaultExecutorField = StatsMonitor.class.getDeclaredField("DEFAULT_EXECUTOR");
+        Field unsafeField = Unsafe.class.getDeclaredField("theUnsafe");
+        unsafeField.setAccessible(true);
+        Unsafe unsafe = (Unsafe) unsafeField.get(null);
+        long offset = unsafe.staticFieldOffset(defaultExecutorField);
+        Object base = unsafe.staticFieldBase(defaultExecutorField);
+        unsafe.putObject(base, offset, Executors.newSingleThreadScheduledExecutor());
 
         PeerEurekaNode node = eurekaNodes.createPeerEurekaNode("https://localhost:10013/");
         assertInstanceOf(ApimlPeerEurekaNode.class, node);

gradle/versions.gradle

@@ -112,7 +112,7 @@ dependencyResolutionManagement {
             version('micronautPlugin', '4.6.2')
             version('shadow', '9.4.2')
             version('checkstyle', '10.17.0')
-            version('jacoco', '0.8.11')
+            version('jacoco', '0.8.15')
             version('gradle', '9.0')
             version('commonsCompress', '1.28.0')
             version('bucket4j', '8.19.0')
@@ -299,12 +299,10 @@ dependencyResolutionManagement {
             // Pure Java dependencies - do not use in Spring unless really necessary
             version('logback', '1.5.35')
             version('mockitoCore', '5.23.0')
-            version('mockitoInline', '5.2.0')
             version('mockServer','5.15.0')
 
             library('logback_classic', 'ch.qos.logback', 'logback-classic').versionRef('logback')
             library('mockito_core', 'org.mockito', 'mockito-core').versionRef('mockitoCore')
-            library('mockito_inline', 'org.mockito', 'mockito-inline').versionRef('mockitoInline')
             library('mockito_junit_jupiter', 'org.mockito', 'mockito-junit-jupiter').versionRef('mockitoCore')
             library('mock_server','org.mock-server','mockserver-netty').versionRef('mockServer')
 

zaas-service/build.gradle

@@ -106,7 +106,6 @@ dependencies {
 
     testImplementation libs.awaitility
     testImplementation libs.mockito.core
-    testImplementation libs.mockito.inline
     testImplementation libs.spring.mock.mvc
     testImplementation libs.spring.boot.starter.test
     testImplementation libs.rest.assured

zosmf-jwt-check/src/test/java/org/zowe/apiml/zosmf/jwt/check/HttpClientWrapperTest.java

@@ -151,11 +151,15 @@ void readBodyReturnsNullWhenStreamThrows() throws IOException {
             HttpClientWrapper client = new HttpClientWrapper();
             URL url = new URL("http://localhost:" + port + "/broken");
 
-            HttpClientWrapper.Response response = client.executeCall(url, null);
-
-            assertEquals(200, response.getStatusCode());
-            // readBody returns either truncated content or null if stream throws
-            // The body should be empty string or null depending on timing
+            try {
+                HttpClientWrapper.Response response = client.executeCall(url, null);
+                // Java 17: getResponseCode() returns 200, readBody handles stream errors
+                assertEquals(200, response.getStatusCode());
+            } catch (java.net.SocketException e) {
+                // Java 25: getResponseCode() throws SocketException when the server
+                // prematurely closes the connection before sending the full response body
+                assertTrue(e.getMessage().contains("Unexpected end of file"));
+            }
         }
     }