From e761a072fe198e7f091831417c2f25f055ee58ec Mon Sep 17 00:00:00 2001 From: Arnout Engelen Date: Tue, 4 Dec 2018 12:29:27 +0100 Subject: [PATCH] Widen timeout to fix ClusterShardingPersistenceSpec #25936 --- .../typed/scaladsl/ClusterShardingPersistenceSpec.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/akka-cluster-sharding-typed/src/test/scala/akka/cluster/sharding/typed/scaladsl/ClusterShardingPersistenceSpec.scala b/akka-cluster-sharding-typed/src/test/scala/akka/cluster/sharding/typed/scaladsl/ClusterShardingPersistenceSpec.scala index e1932f03e1..2253d995ee 100644 --- a/akka-cluster-sharding-typed/src/test/scala/akka/cluster/sharding/typed/scaladsl/ClusterShardingPersistenceSpec.scala +++ b/akka-cluster-sharding-typed/src/test/scala/akka/cluster/sharding/typed/scaladsl/ClusterShardingPersistenceSpec.scala @@ -183,7 +183,7 @@ class ClusterShardingPersistenceSpec extends ScalaTestWithActorTestKit(ClusterSh (1 to 10).foreach { n ⇒ ref ! PassivateAndPersist(n.toString)(p1.ref) // recoveryCompleted each time, verifies that it was actually stopped - recoveryProbe.expectMessage("recoveryCompleted:" + (1 until n).map(_.toString).mkString("|")) + recoveryProbe.expectMessage(max = 10.seconds, "recoveryCompleted:" + (1 until n).map(_.toString).mkString("|")) p1.expectMessage(Done) }