Какой 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)
Для встроенного плагина журнала памяти следует использовать идентификатор плагина:
akka.persistence.journal.inmem
По сути, это ключ, который код плагина использует для поиска конфигураций, необходимых для запуска, посмотрите @ https://github.com/akka/akka/blob/master/akka-persistence/src/main/resources/reference.conf