【发布时间】:2016-04-25 17:17:13
【问题描述】:
我应该将哪个readJournalPluginId 与 inmem 日志插件一起使用?
"akka.persistence.journal.plugin" -> "akka.persistence.journal.inmem"
PersistenceQuery(system).readJournalFor[???](???)
【问题讨论】:
标签: scala akka akka-persistence
我应该将哪个readJournalPluginId 与 inmem 日志插件一起使用?
"akka.persistence.journal.plugin" -> "akka.persistence.journal.inmem"
PersistenceQuery(system).readJournalFor[???](???)
【问题讨论】:
标签: scala akka akka-persistence
如果你使用这个依赖:
"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/reference.conf
【讨论】: