From fad6024596fbea5da83b091aa026a760bab8eeee Mon Sep 17 00:00:00 2001 From: Patrik Nordwall Date: Tue, 2 Oct 2012 10:39:22 +0200 Subject: [PATCH] Mute deadletters in ScatterGatherRoutedRemoteActorSpec, see #2010 --- .../router/ScatterGatherRoutedRemoteActorSpec.scala | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/akka-remote-tests/src/multi-jvm/scala/akka/remote/router/ScatterGatherRoutedRemoteActorSpec.scala b/akka-remote-tests/src/multi-jvm/scala/akka/remote/router/ScatterGatherRoutedRemoteActorSpec.scala index a6d7b73d85..d4d125e411 100644 --- a/akka-remote-tests/src/multi-jvm/scala/akka/remote/router/ScatterGatherRoutedRemoteActorSpec.scala +++ b/akka-remote-tests/src/multi-jvm/scala/akka/remote/router/ScatterGatherRoutedRemoteActorSpec.scala @@ -10,11 +10,12 @@ import akka.actor.ActorRef import akka.actor.Props import scala.concurrent.Await import akka.pattern.ask -import akka.remote.testkit.{STMultiNodeSpec, MultiNodeConfig, MultiNodeSpec} +import akka.remote.testkit.{ STMultiNodeSpec, MultiNodeConfig, MultiNodeSpec } import akka.routing.Broadcast import akka.routing.ScatterGatherFirstCompletedRouter import akka.routing.RoutedActorRef import akka.testkit._ +import akka.testkit.TestEvent._ import scala.concurrent.util.duration._ import akka.actor.PoisonPill import akka.actor.Address @@ -50,11 +51,13 @@ class ScatterGatherRoutedRemoteActorSpec extends MultiNodeSpec(ScatterGatherRout with STMultiNodeSpec with ImplicitSender with DefaultTimeout { import ScatterGatherRoutedRemoteActorMultiJvmSpec._ - def initialParticipants = 4 + def initialParticipants = roles.size "A new remote actor configured with a ScatterGatherFirstCompleted router" must { "be locally instantiated on a remote node and be able to communicate through its RemoteActorRef" taggedAs LongRunningTest in { + system.eventStream.publish(Mute(EventFilter.warning(pattern = ".*received dead letter from.*"))) + runOn(first, second, third) { enterBarrier("start", "broadcast-end", "end", "done") } @@ -89,6 +92,8 @@ class ScatterGatherRoutedRemoteActorSpec extends MultiNodeSpec(ScatterGatherRout system.stop(actor) enterBarrier("done") } + + enterBarrier("done") } } }