From 69fd98a39da281d60dab7534ab1c71b582c411e5 Mon Sep 17 00:00:00 2001 From: Christopher Batey Date: Fri, 19 Jul 2019 15:27:08 +0100 Subject: [PATCH] Fix SurviveNetworkInstabilitySpec (#27383) --- .../scala/akka/cluster/SurviveNetworkInstabilitySpec.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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")