Hooking Akka DeadLetterActorRef

Question

Согласно документации Akka, DeadLetterActorRef является:

реализация по умолчанию службы мертвой буквы, к которым Akka маршруты все сообщения, чьи направления закрыты или не существует.

Если бы я хотел «нажать на» мертвые письма после того, как актер прекращается, я просто как-то «зацепить» это DeadLetterActorRef и заставить его передать мне все, что он принимает? Или я подклассифицирую его? Или я делаю что-то совсем другое? В любом случае, как?

Answer 1

Вы можете прослушивать поток событий для событий мертвой буквы. Что-то вроде этого:

import akka.actor._ 

class DeadLetterListener extends Actor { 
    override def preStart { 
    context.system.eventStream.subscribe(self, classOf[DeadLetter]) 
    } 

    override def postStop { 
    context.system.eventStream.unsubscribe(self) 
    } 

    def receive = { 
    case DeadLetter(msg, from, to) => 
     //handle the deadletter here 
    } 
}