问题标签 [akka-persistent-fsm]

我正在开发一个基于 Akka Persistent FSM 的项目。尤其是：

1. 我想知道构建独立测试用例的最佳方法是什么？由于状态更改是持久的（这在文档中没有得到很好的解释，但可以在这里看到），确保我的持久参与者始终以干净的状态开始可能会很棘手。是否有必要手动将重置构建到我的演员 FSM 协议中？如果是这样，这似乎并不理想，因为它是需要自行测试的新行为。

2. 在测试中管理期刊本身的最佳方式是什么？有没有一种简单的方法来配置使用不同的日志进行测试，而不必在角色设计本身中明确选择？文档的插件 TCK部分提到手动删除整个日志文件。这对于测试插件本身来说似乎是合理的，但对于应用程序代码来说，这似乎是一种不必要的低级解决方案。也许我需要在测试拆解中显式调用日志的asyncDeleteMessagesTo？这看起来仍然相当低级，但也许它只是尚未内置到库中的基础设施。

我使用了配置为 sql server 插件的持久性actor。下面是我的 hocon 配置。

这里数据源连接字符串设置为我的本地主机。

是否可以在演员系统初始化之前从 C# 代码中设置此连接字符串？

我在 app.config 文件中有我的主要 hocon 配置，并尝试使用后备配置从后面的代码中设置连接字符串。但是当演员系统启动时它不起作用。这是我的 hocon 配置和 C# 代码，如下所示。有人能帮助我吗？

Hocon 配置我已经注释掉连接字符串以从后备配置 akka.persistence {

文件后面的 C# 代码

我目前有 Akka 和 Cassandra 支持的事件源服务。这是一个名为 AuctionService 的投标系统，有时我需要检索最后一个名为BiddenOnLot. 为此，我使用akka-persistence-query.

这是我当前的代码：

到目前为止，我遍历所有事件并可以确定其类型。但我真的很难隔离最后一个出价事件并能够异步使用它。有任何想法吗？

我正在使用带有 PersistentFSM 的 akka，并希望能够在应用事件后使用 stateData 值回复消息

BidPlacedReply 是一个具有 apply 方法的对象，该方法允许基于我的 stateData 的某些字段构造 BidPlacedReply，例如，我希望能够使用包含当前最高投标人 ID、最高投标人价格的 BidPlacedReply 进行回复......和此值在修改状态并产生“stateAfter”的 applyEvent 中计算。

不幸的是，“回复 BidPlacedReply(stateData)”方法在应用 applyEvent 之前使用 stateData 值调用 BidPlacedReply.apply 方法（这就是我在日志中看到的），

我尝试了以下构造，但它没有修改下一条消息的 stateData（需要调用应用程序！！！）

有谁知道我如何回复与 applyEvent 的结果相对应的 stateData 值（stateData“之后”）？

我正在使用 OpenDaylight 并尝试用 Apache Ignite 替换默认的分布式数据库。我这里使用的是源代码获得的jar。 https://github.com/Romeh/akka-persistance-ignite

但是，IgniteWriteJournal 类似乎没有加载，我通过在其构造函数中放置一些打印语句进行了检查。

.conf 文件有问题吗？

以下是我在 OpenDaylight 中使用的 akka.conf 文件的一部分。