我正在使用 Akka 并使用 ask 方法发送消息
val future: Future = actor ? msg
但是当我试图将那个演员替换为 时PersistentActor with AtLeastOnceDeliveryLike
,未来永远不会完成并且会因超时而倒下。
是否可以通过 ask 方法使用 Akka Persistent Actor?
我正在使用 Akka 并使用 ask 方法发送消息
val future: Future = actor ? msg
但是当我试图将那个演员替换为 时PersistentActor with AtLeastOnceDeliveryLike
,未来永远不会完成并且会因超时而倒下。
是否可以通过 ask 方法使用 Akka Persistent Actor?
我不认为这会起作用,因为actor
必须在回复中做整个delivery
/confirmDelivery
跳舞。我想可能可以创建一个ask
类似的模式来将其抽象出来,但似乎存在一个问题,即询问的哪一方具有至少一次交付语义,以及记账的具体内容。