Akka 2.6如何在Akka中读“死信”？

Question

我读过以下文档https://doc.akka.io/docs/akka/current/general/message-delivery-reliability.html#deal-letters，其中写道：

参与者可以订阅事件流上的类Akka.actor.deadletter，请参见event stream以了解如何做到这一点。

import akka.actor.ActorRef;
import akka.actor.ActorSystem;

final ActorSystem system = ActorSystem.create("DeadLetters");
final ActorRef actor = system.actorOf(Props.create(DeadLetterActor.class));
system.getEventStream().subscribe(actor, DeadLetter.class);

但是在Akka Typed中，Akka.actor.Typed.actorSystem.EventStream()中没有名为subscribe()的方法。

Answer 1

在创建了处理消息类型DeadLetter的类型化ActorSystem和类型化Actor之后，您应该能够订阅EventStream，如下所示。

import akka.actor.typed.eventstream.EventStream;

system.eventStream().tell(new EventStream.Subscribe(DeadLetter.class, actor));