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

Fix compile error in multi-jvm test

Browse source
This commit is contained in:
Mikhail Limansky 2020-01-13 13:27:30 +03:00
parent 3f6a92aecf
commit c23e3a53dd
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-cluster/src/multi-jvm/scala/akka/cluster/routing/ClusterConsistentHashingGroupSpec.scala
View file

@ -73,9 +73,9 @@ abstract class ClusterConsistentHashingGroupSpec
for (_ <- 1 to 10; k <- keys) { router ! k } for (_ <- 1 to 10; k <- keys) { router ! k }
enterBarrier("messages-sent") enterBarrier("messages-sent")
router ! Broadcast(Get) router ! Broadcast(Get)
val a = expectMsgType[Collected].messages val a = expectMsgType[ClusterConsistentHashingGroupMultiJvmSpec.Collected].messages
val b = expectMsgType[Collected].messages val b = expectMsgType[ClusterConsistentHashingGroupMultiJvmSpec.Collected].messages
val c = expectMsgType[Collected].messages val c = expectMsgType[ClusterConsistentHashingGroupMultiJvmSpec.Collected].messages
a.intersect(b) should ===(Set.empty) a.intersect(b) should ===(Set.empty)
a.intersect(c) should ===(Set.empty) a.intersect(c) should ===(Set.empty)