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

harden another case in ClusterShardingSpec, #23006

Browse source 
* 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
This commit is contained in:
Patrik Nordwall 2017-05-23 07:24:02 +02:00
parent d46dc6946b
commit bf6cd6d2c7
1 changed files with 5 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

7
akka-cluster-sharding/src/multi-jvm/scala/akka/cluster/sharding/ClusterShardingSpec.scala
View file

@ -828,8 +828,11 @@ abstract class ClusterShardingSpec(config: ClusterShardingSpecConfig) extends Mu
expectMsg(ActorIdentity(3, None)) expectMsg(ActorIdentity(3, None))
//Check counter 13 is alive again //Check counter 13 is alive again
system.actorSelection(shard / "13") ! Identify(4) val probe3 = TestProbe()
expectMsgType[ActorIdentity](3 seconds).ref should not be (None) 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") enterBarrier("after-13")