From 7bbac405c35f21c173af6e5e6765a53d24ed2b95 Mon Sep 17 00:00:00 2001 From: Arnout Engelen Date: Mon, 5 Nov 2018 14:15:49 +0100 Subject: [PATCH] Widen timeout waiting for sharding to initialize (#25752) (#25856) --- .../cluster/sharding/typed/MultiDcClusterShardingSpec.scala | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/akka-cluster-sharding-typed/src/multi-jvm/scala/akka/cluster/sharding/typed/MultiDcClusterShardingSpec.scala b/akka-cluster-sharding-typed/src/multi-jvm/scala/akka/cluster/sharding/typed/MultiDcClusterShardingSpec.scala index 33752bc759..bad25ab1c3 100644 --- a/akka-cluster-sharding-typed/src/multi-jvm/scala/akka/cluster/sharding/typed/MultiDcClusterShardingSpec.scala +++ b/akka-cluster-sharding-typed/src/multi-jvm/scala/akka/cluster/sharding/typed/MultiDcClusterShardingSpec.scala @@ -4,7 +4,8 @@ package akka.cluster.sharding.typed -import akka.actor.typed.{ ActorRef, Props } +import scala.concurrent.duration._ +import akka.actor.typed.ActorRef import akka.cluster.sharding.typed.scaladsl.EntityTypeKey import akka.cluster.sharding.typed.scaladsl.ClusterSharding import akka.cluster.sharding.typed.scaladsl.Entity @@ -75,7 +76,7 @@ abstract class MultiDcClusterShardingSpec extends MultiNodeSpec(MultiDcClusterSh NoMore)) val probe = TestProbe[Pong] shardRegion ! ShardingEnvelope(entityId, Ping(probe.ref)) - probe.expectMessage(Pong(cluster.selfMember.dataCenter)) + probe.expectMessage(max = 10.seconds, Pong(cluster.selfMember.dataCenter)) enterBarrier("sharding-started") }