作为对死信的测试

Question

我如何在测试时对 Akka 中的死信进行断言？ 我有一个 actor 可以切换行为（使用 become）并处理使用单独的 Dispatcher 调度的一些 Futures。在某些特定条件下，它应该简单地拒绝其他消息。 那些正确地进入死信，但我想尝试为他们断言（或缺乏）。我该怎么做？

Answer 1

死信是使用事件流传递的，因此您可以在测试中使用探针订阅它并验证消息或缺少消息

system.eventStream.subscribe(probe, classOf[DeadLetter])