2

我应该将哪个readJournalPluginId与 inmem 日记插件一起使用?

"akka.persistence.journal.plugin" -> "akka.persistence.journal.inmem"

PersistenceQuery(system).readJournalFor[???](???)
4

2 回答 2

2

如果您使用此依赖项:

"com.github.dnvriend" %% "akka-persistence-inmemory" % "1.2.11"

这个包中的一个:

akka.persistence.inmemory.query.journal.scaladsl._

基本上:

PersistenceQuery(system).readJournalFor[InMemoryReadJournal](InMemoryReadJournal.Identifier)
于 2016-04-25T17:53:15.927 回答
0

对于内置的内存日志插件,您应该使用的插件 ID 是:

akka.persistence.journal.inmem

这本质上是插件代码用来查找启动所需配置的关键,看看@ https://github.com/akka/akka/blob/master/akka-persistence/src/main/resources/参考资料

于 2016-05-12T18:59:18.727 回答