【问题标题】:Akka readJournalPluginId for inmem journal plugin用于 inmem 日志插件的 Akka readJournalPluginId
【发布时间】:2016-04-25 17:17:13
【问题描述】:

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

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

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

【问题讨论】:

    标签: scala akka akka-persistence


    【解决方案1】:

    如果你使用这个依赖:

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

    这个包中的那个:

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

    基本上:

    PersistenceQuery(system).readJournalFor[InMemoryReadJournal](InMemoryReadJournal.Identifier)
    

    【讨论】:

    • 我用的是内置的。
    【解决方案2】:

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

    akka.persistence.journal.inmem
    

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

    【讨论】:

      猜你喜欢
      • 2019-09-16
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2019-03-01
      • 2014-01-20
      相关资源
      最近更新 更多