From 29e759ca55cb223380f90181df26b2f1b2e65c8e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Johan=20Andr=C3=A9n?= Date: Fri, 10 Sep 2021 16:42:46 +0200 Subject: [PATCH] ActorLeakSpec fail fix (#30645) * Wait for a specific association to be lost instead of any association #30639 * Formatting --- .../test/scala/akka/remote/classic/ActorsLeakSpec.scala | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/akka-remote/src/test/scala/akka/remote/classic/ActorsLeakSpec.scala b/akka-remote/src/test/scala/akka/remote/classic/ActorsLeakSpec.scala index 161def3460..88e5d69545 100644 --- a/akka-remote/src/test/scala/akka/remote/classic/ActorsLeakSpec.scala +++ b/akka-remote/src/test/scala/akka/remote/classic/ActorsLeakSpec.scala @@ -21,6 +21,7 @@ import akka.testkit.TestActors.EchoActor object ActorsLeakSpec { val config = ConfigFactory.parseString(""" + akka.loggers = ["akka.testkit.SilenceAllTestEventListener"] akka.actor.provider = remote akka.remote.artery.enabled = false akka.remote.classic.netty.tcp.applied-adapters = ["trttl"] @@ -174,9 +175,11 @@ class ActorsLeakSpec extends AkkaSpec(ActorsLeakSpec.config) with ImplicitSender remoteSystem.terminate() } - EventFilter.warning(pattern = "Association with remote system", occurrences = 1).intercept { - Await.result(remoteSystem.whenTerminated, 10.seconds) - } + EventFilter + .warning(start = s"Association with remote system [${remoteAddress}] has failed", occurrences = 1) + .intercept { + Await.result(remoteSystem.whenTerminated, 10.seconds) + } } // Remote idle for too long case