akka-persistence

2热度

1回答

我有一个使用akka-persistence-jdbc插件和postgresql作为后端的正在运行的项目。现在我想迁移到akka-persistence-cassandra。但是，我怎样才能将现有的事件（postgres中超过4GB大小）转换为cassandra？我应该编写一个手动迁移程序吗？从postgres中读取并在cassandra中写入正确的格式？

2热度

1回答

能否混合持续FSM和AT-至少一次消息在阿卡递送

阿卡提供持久演员与一次在-至少消息递送（link）持久FSM（link）我可以将两者搅和？我希望能够保持持久状态机，但也有阶段的变化触发其发送消息给其他演员有一次在-至少消息提供担保

3热度

1回答

需要DB调用的CQRS命令验证

在CQRS中，验证需要数据库调用的命令的最佳方法是什么？例如，我有Order聚合，验证命令说CommitOrder，我不想接受这个命令，除非有足够的股票。在这种情况下，命令处理程序如何检查是否有订单项的库存或不存在？我可以从写入端查询读取端吗？注：我使用的是阿卡实施

2热度

1回答

如何获取导致在Akka持续时间重新启动的消息

我有PersistenceActor，我想在preRestart方法中根据消息执行某些操作，从而导致重新启动。对于普通的演员，这将是容易的，因为有消息传递给preRestart方法： def preRestart(reason: Throwable, message: Option[Any]) 但是对于PersistentActor不能以这种方式来完成，因为每次None被作为消息传递的属性。它

0热度

1回答

Akka（JVM）Azure事件采购？

我想在Azure上部署一个使用日志持久性插件的Akka应用程序。对于我应该使用的持久性插件，我找不到工作组合。到目前为止，我看着：阿卡余辉，蒙戈和Azure的文档存储与蒙戈司机：这是行不通的，因为阿卡的持久性 - 蒙戈是不是使用支持SSL最新的无功蒙戈版本兼容阿卡余辉-JDBC和Azure的SQL服务器：看来阿卡持久性-JDBC是只用油滑H2，Oracle和MySQL驱动兼容的，我没有任

0热度

2回答

如何在节点崩溃的情况下恢复akka actor中排队的消息？

如果节点崩溃并且在该时间点邮件在邮箱中排队，那么这些邮件将如何重新处理？如果他们不能被重新处理，那么我们怎么能说akka编程模型是容错的。这是我们现在必须使用持久队列的最基本的用例。

6热度

1回答

是否有使用快照与PersistenceQuery

PersistentView已经在阿卡2.4被弃用的方式。文档建议改用PersistenceQuery。但PersistenceQuery似乎仅限于事件日记，但无法查询快照存储。恢复从大量事件的状态需要一定的时间，所以要使用快照的能力是非常重要的我。是弃用提前在这里它的时间点吗？我应该继续与PersistentView合作还是错过了一些东西？如何仅使用PersistenceQuery处理快照？

0热度

1回答

Akka持久性和Mongodb：重放persistenceId事件时的持续性失败

我是uisng akka-persistence使用此mongodb https://github.com/ironfish/akka-persistence-mongo/ mongodb插件。当我运行我的代码，我收到以下错误： [ERROR] [11/19/2016 16:47:29.355] [transaction-system-akka.actor.default-dispatcher-5

1热度

1回答

Play框架，Akka持久性，PersistenceQuery，无法将Source转换为Action.async的Future对象

我试图获取持久化事件列表并将其作为响应发送（Action.async）。但我无法将PersistenceQuery结果转换为Future对象。下面是代码 val queries = PersistenceQuery(actorSystem).readJournalFor[CassandraReadJournal](CassandraReadJournal.Identifier) val sour

2热度

1回答

奇怪的斯卡拉与全局变量的测试行为：包括延迟使其成功

首先，整个代码是在https://github.com/JJ/spray-test 我使用全局对象（我不知道它是否是斯卡拉适当的行为）共享状态在喷雾应用程序。 put添加到一个地图，get从地图获得的值，从而： path(Segment) { quien => get { println(Apuestas) // also Thread.wait(100) val