make testActor spew out uncollected messages after test end

(so you don’t need expectNoMsg after tests)
This commit is contained in:
Roland 2011-12-05 18:52:32 +01:00
parent d2cffe7e33
commit c0c9487451
2 changed files with 36 additions and 6 deletions

View file

@ -39,6 +39,11 @@ class TestActor(queue: BlockingDeque[TestActor.Message]) extends Actor {
val observe = ignore map (ignoreFunc if (ignoreFunc isDefinedAt x) !ignoreFunc(x) else true) getOrElse true
if (observe) queue.offerLast(RealMessage(x, sender))
}
override def postStop() = {
import scala.collection.JavaConverters._
queue.asScala foreach { m system.deadLetters ! DeadLetter(m.msg, m.sender, self) }
}
}
/**