diff --git a/akka-cluster/src/multi-jvm/scala/akka/cluster/SurviveNetworkInstabilitySpec.scala b/akka-cluster/src/multi-jvm/scala/akka/cluster/SurviveNetworkInstabilitySpec.scala
index 07b3c73d04..2e7ed963ef 100644
--- a/akka-cluster/src/multi-jvm/scala/akka/cluster/SurviveNetworkInstabilitySpec.scala
+++ b/akka-cluster/src/multi-jvm/scala/akka/cluster/SurviveNetworkInstabilitySpec.scala
@@ -287,7 +287,7 @@ abstract class SurviveNetworkInstabilitySpec
         system.actorOf(Props[Watcher], "watcher")
 
         // undelivered system messages in RemoteChild on third should trigger QuarantinedEvent
-        system.eventStream.subscribe(testActor, classOf[QuarantinedEvent])
+        system.eventStream.subscribe(testActor, quarantinedEventClass)
       }
       enterBarrier("watcher-created")
 
@@ -312,7 +312,7 @@ abstract class SurviveNetworkInstabilitySpec
         within(10.seconds) {
           quarantinedEventFrom(expectMsgClass(quarantinedEventClass)) should ===(address(second))
         }
-        system.eventStream.unsubscribe(testActor, classOf[QuarantinedEvent])
+        system.eventStream.unsubscribe(testActor, quarantinedEventClass)
       }
       enterBarrier("quarantined")