From bf6cd6d2c73ffdb31e9f1e8dd48c66fc6eda64af Mon Sep 17 00:00:00 2001 From: Patrik Nordwall Date: Tue, 23 May 2017 07:24:02 +0200 Subject: [PATCH] harden another case in ClusterShardingSpec, #23006 * due to the new StartEntity message the start is not as instant as it used to be and therefore the test must retry this check --- .../scala/akka/cluster/sharding/ClusterShardingSpec.scala | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/akka-cluster-sharding/src/multi-jvm/scala/akka/cluster/sharding/ClusterShardingSpec.scala b/akka-cluster-sharding/src/multi-jvm/scala/akka/cluster/sharding/ClusterShardingSpec.scala index 72fc03f350..84d550e2f8 100644 --- a/akka-cluster-sharding/src/multi-jvm/scala/akka/cluster/sharding/ClusterShardingSpec.scala +++ b/akka-cluster-sharding/src/multi-jvm/scala/akka/cluster/sharding/ClusterShardingSpec.scala @@ -828,8 +828,11 @@ abstract class ClusterShardingSpec(config: ClusterShardingSpecConfig) extends Mu expectMsg(ActorIdentity(3, None)) //Check counter 13 is alive again - system.actorSelection(shard / "13") ! Identify(4) - expectMsgType[ActorIdentity](3 seconds).ref should not be (None) + val probe3 = TestProbe() + awaitAssert({ + system.actorSelection(shard / "13").tell(Identify(4), probe3.ref) + probe3.expectMsgType[ActorIdentity](1 second).ref should not be (None) + }, 5 seconds, 500 millis) } enterBarrier("after-13")