From aee0152da2a05a0953652832d6f3225cf7b2f480 Mon Sep 17 00:00:00 2001 From: Helena Edelson Date: Tue, 10 Sep 2019 00:22:53 -0700 Subject: [PATCH] Failed: MultiDcClusterSharding #27663 (#27666) --- .../cluster/sharding/typed/MultiDcClusterShardingSpec.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 982014a5ab..2c024e716c 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 @@ -69,7 +69,7 @@ abstract class MultiDcClusterShardingSpec val shardRegion: ActorRef[ShardingEnvelope[PingProtocol]] = sharding.init(Entity(typeKey, _ => multiDcPinger)) val probe = TestProbe[Pong] shardRegion ! ShardingEnvelope(entityId, Ping(probe.ref)) - probe.expectMessage(max = 10.seconds, Pong(cluster.selfMember.dataCenter)) + probe.expectMessage(max = 15.seconds, Pong(cluster.selfMember.dataCenter)) enterBarrier("sharding-initialized") }