akka-persistence

1热度

1回答

我正在用阿卡持久性构建应用程序。我必须正确检测并处理持久性故障。这怎么可能？它会抛出任何持久性异常吗？这里是我到现在为止 override def receiveRecover: Receive = { ... } override def receiveCommand: Receive = { case WorkIsDone(workerId, workId, result) =>

4热度

3回答

当演员状态只增加大小时，我可以使用阿卡保持吗？

我正在玩akka持久性试图实现一个服务，其中我的状态是一个潜在的非常大的（好吧，让我们说它不适合RAM）一些实体列表。假设用户希望所有实体的所有历史记录都可用。我可以在akka持久性中做到这一点吗？现在我的演员状态看起来像那样。 case class System(var processes: Map[Long, Process] = Map()) { def updated(eve

2热度

1回答

PersistentActor不能在未来的onComplete中调用persist处理程序

当我尝试从未来的onComplete中调用updateState时，我使用PersistentActor，非常新，失败，没有任何happanes，试图调试它，并且我确实接触到持续调用但未进入在updateState trait Event case class Cmd(data: String) case class Evt(data: String) extends Event cla

1热度

2回答

如何在单元测试中杀死并重启akka persistent actor以查看它是否保留状态

在我的单元测试中，有没有一种方法可以杀死然后重新启动一个持久actor以检查它是否可以正确保留状态（并且，例如，事件序列化/反序列化工作正常）？

3热度

1回答

如何向CQRS中的命令发送响应？

我正在实现一个具有Akka持久性的CQRS系统，并且我试图理解CQRS的请求响应位。关于如何向客户端发送响应，SO上的答案很少，this article也提到了一些很好的模式。但是，不要泛泛而谈使用大词汇，有人可以解释我应该如何将响应发回CQRS中的客户端以用于以下简单用例。使用情况假设用户是显示用户配置文件，显示以下信息的页面上用户名地址电话号码在我的系统中，我有一个A.每个用户存

2热度

1回答

AtLeastOnceDelivery不适用于akka-persistence问题？

我用用阿卡和使用要求的方法 val future: Future = actor ? msg 发送消息但是，当我试图更换演员PersistentActor with AtLeastOnceDeliveryLike，未来是永远不会完成，并跌倒与超时。是否可以使用Akka Persistent Actor与ask方法？

0热度

1回答

缺少参数类型扩展功能的单位斯卡拉

我试图包装一些演员接收代码在db事务来构建idempotent持久视图，通过更新数据库中的信息来处理事件。 class TrajectoryView extends IdempotentView { override def viewId: String = "trajectoryView" override def persistenceId: String = "sa

0热度

2回答

有没有办法说明持久性后端在使用持久性actor时无法访问？

我正在使用EventStore作为后端在Scala中执行一个演员。测试是基于specs2的。在规范类的初始化，正被实例化的其他类的构造函数中，我要求我的演员的东西，如果EventStore没有运行，出现因 akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka://com-optrak-opkakka-authenticati

4热度

1回答

如何测试Akka Persistence actor

我正在开发基于Akka Persistent FSM的项目。特别是：我想知道为独立性构建测试用例的最佳方法是什么？由于状态改变是持久的（这在文档中没有很好的解释，但可以看到here），确保我的持久性actor始终处于干净状态可能会非常棘手。是否需要手动将复位构建到演员FSM协议中？如果是这样，这看起来并不理想，因为它是需要自行测试的新行为。在测试中管理期刊本身的最佳方式是什么？有没有简单的方法

3热度

1回答

是否比我更好地将akka持久存储在redis中的消息状态？

我目前喜欢在akka上使用redis，因为我可以通过查询redis来监视哪些消息已经被处理。 Redis也坚持磁盘。与仅使用redis相比，akka持久性如何？