我应该将哪个readJournalPluginId
与 inmem 日记插件一起使用?
"akka.persistence.journal.plugin" -> "akka.persistence.journal.inmem"
PersistenceQuery(system).readJournalFor[???](???)
我应该将哪个readJournalPluginId
与 inmem 日记插件一起使用?
"akka.persistence.journal.plugin" -> "akka.persistence.journal.inmem"
PersistenceQuery(system).readJournalFor[???](???)
如果您使用此依赖项:
"com.github.dnvriend" %% "akka-persistence-inmemory" % "1.2.11"
这个包中的一个:
akka.persistence.inmemory.query.journal.scaladsl._
基本上:
PersistenceQuery(system).readJournalFor[InMemoryReadJournal](InMemoryReadJournal.Identifier)
对于内置的内存日志插件,您应该使用的插件 ID 是:
akka.persistence.journal.inmem
这本质上是插件代码用来查找启动所需配置的关键,看看@ https://github.com/akka/akka/blob/master/akka-persistence/src/main/resources/参考资料