diff --git a/akka-cluster/src/multi-jvm/scala/akka/cluster/routing/ClusterConsistentHashingGroupSpec.scala b/akka-cluster/src/multi-jvm/scala/akka/cluster/routing/ClusterConsistentHashingGroupSpec.scala index 2c786c1909..794dea532f 100644 --- a/akka-cluster/src/multi-jvm/scala/akka/cluster/routing/ClusterConsistentHashingGroupSpec.scala +++ b/akka-cluster/src/multi-jvm/scala/akka/cluster/routing/ClusterConsistentHashingGroupSpec.scala @@ -73,9 +73,9 @@ abstract class ClusterConsistentHashingGroupSpec for (_ <- 1 to 10; k <- keys) { router ! k } enterBarrier("messages-sent") router ! Broadcast(Get) - val a = expectMsgType[Collected].messages - val b = expectMsgType[Collected].messages - val c = expectMsgType[Collected].messages + val a = expectMsgType[ClusterConsistentHashingGroupMultiJvmSpec.Collected].messages + val b = expectMsgType[ClusterConsistentHashingGroupMultiJvmSpec.Collected].messages + val c = expectMsgType[ClusterConsistentHashingGroupMultiJvmSpec.Collected].messages a.intersect(b) should ===(Set.empty) a.intersect(c) should ===(Set.empty)