raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

StreamRefs spec fail (#28018)

Browse source 
* Wrong timeout used for subscription timeout

(cherry picked from commit 05098eef1d9ecdbb5f0c8c5cda29aa1890ddc9e6)
This commit is contained in:
Johan Andrén 2019-10-17 08:46:15 +02:00 • committed by Patrik Nordwall
parent c13fa76ab5
commit 8c5a0fac8e
1 changed files with 2 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

3
akka-cluster/src/multi-jvm/scala/akka/cluster/StreamRefSpec.scala
View file

@ -37,6 +37,7 @@ object StreamRefSpec extends MultiNodeConfig {
commonConfig( commonConfig(
debugConfig(on = false) debugConfig(on = false)
.withFallback(ConfigFactory.parseString(""" .withFallback(ConfigFactory.parseString("""
akka.stream.materializer.stream-ref.subscription-timeout = 10 s
akka.cluster { akka.cluster {
downing-provider-class = akka.cluster.testkit.AutoDowning downing-provider-class = akka.cluster.testkit.AutoDowning
testkit.auto-down-unreachable-after = 1s 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 // and it triggered the subscription timeout. Therefore we must wait more than the
// the subscription timeout for a failure // the subscription timeout for a failure
val timeout = system.settings.config val timeout = system.settings.config
.getDuration("akka.stream.materializer.subscription-timeout.timeout") .getDuration("akka.stream.materializer.stream-ref.subscription-timeout")
.asScala + 2.seconds .asScala + 2.seconds
streamLifecycle3.expectMsg(timeout, "failed-system-42-tmp") streamLifecycle3.expectMsg(timeout, "failed-system-42-tmp")
} }