Merge branch 'master' into quintenp/netty

Author: quintenp01

common/scala/build.gradle

@@ -198,6 +198,7 @@ dependencies {
         api("ch.qos.logback:logback-core:1.2.13")
         api("io.netty:netty-codec:${gradle.netty.version}")
         api("io.netty:netty-common:${gradle.netty.version}")
+        api("com.fasterxml.jackson.core:jackson-databind:${gradle.jackson.version}")
     }
 }
 
@@ -206,10 +207,10 @@ configurations {
         exclude group: 'commons-logging'
         exclude group: 'log4j'
     }
-    all {
+    configureEach {
         resolutionStrategy.dependencySubstitution {
             // CVE-2025-12183, CVE-2025-66566: org.lz4:lz4-java relocated to at.yawk.lz4 transitive dependency of kafka-clients
-            substitute module('org.lz4:lz4-java') using module('at.yawk.lz4:lz4-java:1.10.3')
+            substitute module("org.lz4:lz4-java") using module("at.yawk.lz4:lz4-java:1.10.3")
         }
     }
 }

settings.gradle

@@ -109,4 +109,5 @@ gradle.ext.grpc = [version : '1.75.0']
 gradle.ext.curator = [version : '5.7.0']
 gradle.ext.kube_client = [version: '4.10.3']
 
+gradle.ext.jackson = [version: '2.21.1']
 gradle.ext.netty = [version : '4.1.132.Final']

tests/src/test/scala/org/apache/openwhisk/core/containerpool/v2/test/InvokerHealthManagerTests.scala

@@ -19,7 +19,7 @@ package org.apache.openwhisk.core.containerpool.v2.test
 
 import org.apache.pekko.actor.FSM.{CurrentState, SubscribeTransitionCallBack, Transition}
 import org.apache.pekko.actor.{ActorRef, ActorRefFactory, ActorSystem}
-import org.apache.pekko.testkit.{ImplicitSender, TestActor, TestFSMRef, TestKit, TestProbe}
+import org.apache.pekko.testkit.{ImplicitSender, TestFSMRef, TestKit, TestProbe}
 import common.StreamLogging
 import org.apache.openwhisk.common.InvokerState.{Healthy, Offline, Unhealthy}
 import org.apache.openwhisk.common.{Enable, GracefulShutdown, RingBuffer}
@@ -331,26 +331,13 @@ class InvokerHealthManagerTests
           instanceId.tags,
           instanceId.dedicatedNamespaces).serialize))
 
-    val mockHealthActionProxy = TestProbe()
-
-    mockHealthActionProxy.setAutoPilot((sender, msg) =>
-      msg match {
-        case _: Initialize =>
-          (1 to InvokerHealthManager.bufferSize - InvokerHealthManager.bufferErrorTolerance) foreach { _ =>
-            sender ! HealthMessage(true)
-          }
-          TestActor.KeepRunning
-
-        case GracefulShutdown =>
-          TestActor.KeepRunning
-    })
-
-    fsm.underlyingActor.healthActionProxy = Some(mockHealthActionProxy.ref)
-
     fsm ! Enable
+    (1 to InvokerHealthManager.bufferSize - InvokerHealthManager.bufferErrorTolerance) foreach { _ =>
+      fsm ! HealthMessage(true)
+    }
 
     probe.expectMsg(Transition(fsm, Offline, Unhealthy))
-    probe.expectMsg(10.seconds, Transition(fsm, Unhealthy, Healthy))
+    probe.expectMsg(Transition(fsm, Unhealthy, Healthy))
 
     dataManagementService.expectMsg(
       UpdateDataOnChange(