diff --git a/akka-cluster/src/multi-jvm/scala/akka/cluster/SplitBrainSpec.scala b/akka-cluster/src/multi-jvm/scala/akka/cluster/SplitBrainSpec.scala index a2398d8ce7..4320f406df 100644 --- a/akka-cluster/src/multi-jvm/scala/akka/cluster/SplitBrainSpec.scala +++ b/akka-cluster/src/multi-jvm/scala/akka/cluster/SplitBrainSpec.scala @@ -24,7 +24,7 @@ case class SplitBrainMultiNodeConfig(failureDetectorPuppet: Boolean) extends Mul commonConfig(debugConfig(on = false). withFallback(ConfigFactory.parseString(""" - akka.remote.retry-latch-closed-for = 3 s + akka.remote.retry-gate-closed-for = 3 s akka.cluster { auto-down = on failure-detector.threshold = 4 diff --git a/akka-remote/src/test/scala/akka/remote/RemotingSpec.scala b/akka-remote/src/test/scala/akka/remote/RemotingSpec.scala index d3667f3158..5455d08424 100644 --- a/akka-remote/src/test/scala/akka/remote/RemotingSpec.scala +++ b/akka-remote/src/test/scala/akka/remote/RemotingSpec.scala @@ -80,7 +80,7 @@ object RemotingSpec { remote { transport = "akka.remote.Remoting" - retry-latch-closed-for = 1 s + retry-gate-closed-for = 1 s log-remote-lifecycle-events = on enabled-transports = [ @@ -212,7 +212,7 @@ class RemotingSpec extends AkkaSpec(RemotingSpec.cfg) with ImplicitSender with D } "send error message for wrong address" in { - filterEvents(EventFilter.error(start = "Association", occurrences = 6), + filterEvents(EventFilter.error(start = "AssociationError", occurrences = 1), EventFilter.warning(pattern = ".*dead letter.*echo.*", occurrences = 1)) { system.actorFor("akka.test://nonexistingsystem@localhost:12346/user/echo") ! "ping" } diff --git a/akka-remote/src/test/scala/akka/remote/transport/AkkaProtocolSpec.scala b/akka-remote/src/test/scala/akka/remote/transport/AkkaProtocolSpec.scala index 2cc5abf338..aa9daf6e94 100644 --- a/akka-remote/src/test/scala/akka/remote/transport/AkkaProtocolSpec.scala +++ b/akka-remote/src/test/scala/akka/remote/transport/AkkaProtocolSpec.scala @@ -56,7 +56,7 @@ class AkkaProtocolSpec extends AkkaSpec("""akka.actor.provider = "akka.remote.Re startup-timeout = 5 s - retry-latch-closed-for = 0 s + retry-gate-closed-for = 0 s use-passive-connections = on } diff --git a/akka-remote/src/test/scala/akka/remote/transport/AkkaProtocolStressTest.scala b/akka-remote/src/test/scala/akka/remote/transport/AkkaProtocolStressTest.scala index 80c0fb2b73..19163c3e6e 100644 --- a/akka-remote/src/test/scala/akka/remote/transport/AkkaProtocolStressTest.scala +++ b/akka-remote/src/test/scala/akka/remote/transport/AkkaProtocolStressTest.scala @@ -16,7 +16,7 @@ object AkkaProtocolStressTest { #loglevel = DEBUG actor.provider = "akka.remote.RemoteActorRefProvider" - remote.retry-latch-closed-for = 0 s + remote.retry-gate-closed-for = 0 s remote.log-remote-lifecycle-events = on remote.failure-detector { diff --git a/akka-remote/src/test/scala/akka/remote/transport/ThrottlerTransportAdapterSpec.scala b/akka-remote/src/test/scala/akka/remote/transport/ThrottlerTransportAdapterSpec.scala index 54b3e5cd2e..282b7efdab 100644 --- a/akka-remote/src/test/scala/akka/remote/transport/ThrottlerTransportAdapterSpec.scala +++ b/akka-remote/src/test/scala/akka/remote/transport/ThrottlerTransportAdapterSpec.scala @@ -19,7 +19,7 @@ object ThrottlerTransportAdapterSpec { actor.provider = "akka.remote.RemoteActorRefProvider" remote.netty.tcp.hostname = "localhost" - remote.retry-latch-closed-for = 0 s + remote.retry-gate-closed-for = 0 s remote.log-remote-lifecycle-events = on remote.netty.tcp.applied-adapters = ["trttl"]