diff --git a/akka-actor-tests/src/test/scala/akka/dispatch/PinnedActorSpec.scala b/akka-actor-tests/src/test/scala/akka/dispatch/PinnedActorSpec.scala index a3d647fcf3..c2b6f93ec2 100644 --- a/akka-actor-tests/src/test/scala/akka/dispatch/PinnedActorSpec.scala +++ b/akka-actor-tests/src/test/scala/akka/dispatch/PinnedActorSpec.scala @@ -2,12 +2,16 @@ package akka.actor.dispatch import java.util.concurrent.{ CountDownLatch, TimeUnit } import org.scalatest.junit.JUnitSuite -import org.junit.Test +import org.junit.{ Test, Before, After } import akka.dispatch.Dispatchers import akka.actor.Actor import Actor._ +import akka.event.EventHandler +import akka.testkit.TestEvent._ +import akka.testkit.EventFilter + object PinnedActorSpec { class TestActor extends Actor { self.dispatcher = Dispatchers.newPinnedDispatcher(self) @@ -26,6 +30,16 @@ class PinnedActorSpec extends JUnitSuite { private val unit = TimeUnit.MILLISECONDS + @Before + def beforeEach { + EventHandler.notify(Mute(EventFilter[RuntimeException]("Failure"))) + } + + @After + def afterEach { + EventHandler.notify(UnMuteAll) + } + @Test def shouldSendOneWay { var oneWay = new CountDownLatch(1)