diff --git a/akka-testkit/src/main/scala/akka/testkit/TestKit.scala b/akka-testkit/src/main/scala/akka/testkit/TestKit.scala index c5cfec6e43..fdad53c4ff 100644 --- a/akka-testkit/src/main/scala/akka/testkit/TestKit.scala +++ b/akka-testkit/src/main/scala/akka/testkit/TestKit.scala @@ -20,6 +20,8 @@ class TestActor(queue : BlockingDeque[AnyRef]) extends Actor with FSM[Int, TestA import FSM._ import TestActor._ + self.dispatcher = CallingThreadDispatcher.global + startWith(0, None) when(0, stateTimeout = 5 seconds) { case Ev(SetTimeout(d)) =>