From 8c5a0fac8edfe25b5a946f89168aa67213556d07 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Johan=20Andr=C3=A9n?= Date: Thu, 17 Oct 2019 08:46:15 +0200 Subject: [PATCH] StreamRefs spec fail (#28018) * Wrong timeout used for subscription timeout (cherry picked from commit 05098eef1d9ecdbb5f0c8c5cda29aa1890ddc9e6) --- .../src/multi-jvm/scala/akka/cluster/StreamRefSpec.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/akka-cluster/src/multi-jvm/scala/akka/cluster/StreamRefSpec.scala b/akka-cluster/src/multi-jvm/scala/akka/cluster/StreamRefSpec.scala index 7a7129bb54..c5281ad997 100644 --- a/akka-cluster/src/multi-jvm/scala/akka/cluster/StreamRefSpec.scala +++ b/akka-cluster/src/multi-jvm/scala/akka/cluster/StreamRefSpec.scala @@ -37,6 +37,7 @@ object StreamRefSpec extends MultiNodeConfig { commonConfig( debugConfig(on = false) .withFallback(ConfigFactory.parseString(""" + akka.stream.materializer.stream-ref.subscription-timeout = 10 s akka.cluster { downing-provider-class = akka.cluster.testkit.AutoDowning testkit.auto-down-unreachable-after = 1s @@ -254,7 +255,7 @@ abstract class StreamRefSpec extends MultiNodeSpec(StreamRefSpec) with MultiNode // and it triggered the subscription timeout. Therefore we must wait more than the // the subscription timeout for a failure val timeout = system.settings.config - .getDuration("akka.stream.materializer.subscription-timeout.timeout") + .getDuration("akka.stream.materializer.stream-ref.subscription-timeout") .asScala + 2.seconds streamLifecycle3.expectMsg(timeout, "failed-system-42-tmp") }