java – Akka – 实现一个自定义的DeadLetterListener actor
发布时间：2020-12-15 04:19:25 所属栏目：Java 来源：网络整理
导读：我正在尝试添加其他行为来处理Akka中的死信.我认为最好的方法是实现我们自己的死信监听器,但我找不到任何关于如何集成我们自己的actor而不是默认死信监听器的文档. 是否有任何关于如何执行此操作的文档(或者是否有其他方法来扩展或覆盖这些默认实现的行为？
|
我正在尝试添加其他行为来处理Akka中的死信.我认为最好的方法是实现我们自己的死信监听器,但我找不到任何关于如何集成我们自己的actor而不是默认死信监听器的文档.
是否有任何关于如何执行此操作的文档(或者是否有其他方法来扩展或覆盖这些默认实现的行为？ 解决方法
您应该为此订阅
EventStream.
import akka.actor.{ Actor,DeadLetter,Props }
class Listener extends Actor {
def receive = {
case d: DeadLetter => println(d)
}
}
val listener = system.actorOf(Props(classOf[Listener]))
system.eventStream.subscribe(listener,classOf[DeadLetter])
（编辑：李大同） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |