akka-persistence

0热度

1回答

Akka.net持久性actor没有从Fallback Config获取连接字符串？

我在app.config文件中有我的主要hocon配置，并尝试从使用后备配置的代码后面设置连接字符串。但是演员系统启动时不起作用。这里是我的hocon配置和C＃代码如下。有人能帮助我吗？ Hocon配置我有注释connnection串把它从备用配置 akka.persistence {隐藏文件 journal { plugin = "akka.persistence.journal.

8热度

2回答

无法激活服务器上的二进制http绑定

我试图在WCF服务中使用二进制消息编码，遵循本网站上的许多示例。在我已在绑定声明为使服务器： <customBinding> <binding name="binaryHttpBinding"> <binaryMessageEncoding maxReadPoolSize="4096000" maxSessionSize="4096000" maxWritePoolSize

1热度

2回答

Akka：如何在重新启动时获取儿童演员

当系统重新启动时，context.children（）调用将为特定的父项返回零个子项。在重新启动之前，context.children（）返回父对象具有的子项的实际数量。有人可以让我知道我们怎么能得到重新启动后的父母子女ActorRef？我的使用情况是：重启之前，有让说，5个孩子家长的。现在，我想计算表现并计算表现，我需要所有这5个孩子的参与。因此，重启后，我可以将同样的信息发送给所有的孩子

2热度

1回答

为什么Akka Persisence Query Read Journal没有检索我的活动？

我有问题了解Akka持久性查询，尤其是方法eventsByTag，因为它不像我所期望的那样。在我的主类中，我调用一个类来开始监听使用某个标签持久化的任何事件。 class CassandraJournal(implicit val system: ActorSystem) { def engageStreaming = { val readJournal = Persistence

1热度

1回答

如何使用Akka持久性查询检索所有日记事件？

阿卡持久性查询有如下预定义的操作： EventsByPersistenceId EventsByTag CurrentEventsByPersistenceId CurrentEventsByTag AllPersistenceIds 但是如果我需要把所有过去的事件，某种进行中...运作的？我无法弄清楚如何以Akka持久性查询术语来实现它。

1热度

1回答

如何在测试中使用其他application.conf而不是prod代码？

即时通讯尝试使用scalatest测试PersistentActor，但我不知道如何指向测试代码以使用像application-test.conf而不是application.conf（我想将事件的leveldb存储更改为内存存储）。有没有方便的方法来做到这一点？

0热度

1回答

Akka.net - 每次创建新对象时加载所有日志数据

每次我在Akka.NET中创建一个新类型的对象时。这种类型的全部期刊被加载在构造我的测试： [Test, Category("Integration")] public async Task Should_Persist_Actor() { var model = Mocks.Fake.Contact(); await Actors.Cont

0热度

1回答

演员问超时在阿卡持久性

我尝试了“你好，世界”的例子与MongoDB的支持阿卡的持久性，使用这个开源，https://github.com/scullxbones/akka-persistence-mongo/tree/master/rxmongo/src。以下是我的代码。然而，当我运行应用程序，我问超时： akka.pattern.AskTimeoutException：2000毫秒]后：//例子/用户/ sample

3热度

1回答

应该制作哪些演员持久？

让我们想象一下一个典型的应用阿卡与像演员的结构树，即小（2-3）的顶级演员这在层次结构的底部管理潜在的成千上万的小演员的数量。看起来有两种方法来持久化：只让顶级行为者持久化。儿童演员靠父母的任何状态恢复等使所有的儿童演员的执着。我们最终可能会有数千个持久性id，每个actor都可以恢复它自己的状态。这些方法之间进行选择时考虑哪些因素有哪些？是否有典型的用例与一个适合，但不适用于另一个？的问

2热度

1回答

akka集群感知路由器和akka集群分片的不同用例？

群集感知路由器： val router = system.actorOf(ClusterRouterPool( RoundRobinPool(0), ClusterRouterPoolSettings( totalInstances = 20, maxInstancesPerNode = 1, allowLocalRoutees = false,