持续存在事件后执行副作用

如何解决持续存在事件后执行副作用

在事件持续存在后，我试图找到执行异步副作用（或某些操作）的最佳方法。

这是我现在正在做的事情，如果有人可以告诉我是否有更好的方法，我将不胜感激。

示例1：

演员A做某事，保留事件，然后使用thenRun和tell模式调用演员B。演员B已使用退避主管重新启动，因此如果失败，它将尝试重试几次它失败了。

var sideEffectActor = this.context.spawn(SideEffectBehavIoUr.create(),"sideEffectBehavior");

return Effect()
    .persist(persistableEvents)
    .thenRun(() -> sideEffectActor.tell(new Message()))
    //...

示例2：

一个更复杂的情况是Actor B需要调用ActorA。在某些情况下，我需要记录与Actor A行为相关的其他事件，但我仍然希望它是异步的。

我做的事情与第一个示例相同，Actor A使用thenRun模式的tell，但是发送给Actor B的消息包含ActorRef。 Actor B使用ask模式在该ActorRef上同步执行逻辑，如果出现故障，请重试。

那么还有更好的方法吗？我的操作方式有什么问题吗？