2

我正在使用 Akka 并使用 ask 方法发送消息

val future: Future = actor ? msg

但是当我试图将那个演员替换为 时PersistentActor with AtLeastOnceDeliveryLike,未来永远不会完成并且会因超时而倒下。

是否可以通过 ask 方法使用 Akka Persistent Actor?

4

1 回答 1

0

我不认为这会起作用,因为actor必须在回复中做整个delivery/confirmDelivery跳舞。我想可能可以创建一个ask类似的模式来将其抽象出来,但似乎存在一个问题,即询问的哪一方具有至少一次交付语义,以及记账的具体内容。

于 2015-10-31T20:27:37.740 回答