class PersistenceQuery extends PersistencePlugin[ReadJournal, ReadJournal, ReadJournalProvider] with Extension
Ordering
- Alphabetic
- By Inheritance
Inherited
- PersistenceQuery
- Extension
- PersistencePlugin
- AnyRef
- Any
Implicitly
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
Visibility
- Public
- All
Instance Constructors
- new PersistenceQuery(system: ExtendedActorSystem)
Value Members
- final def getReadJournalFor[T <: ReadJournal](clazz: Class[T], readJournalPluginId: String): T
-
final
def
getReadJournalFor[T <: ReadJournal](clazz: Class[T], readJournalPluginId: String, readJournalPluginConfig: Config): T
Java API: Returns the akka.persistence.query.javadsl.ReadJournal specified by the given read journal configuration entry.
-
final
def
readJournalFor[T <: ReadJournal](readJournalPluginId: String): T
Scala API: Returns the akka.persistence.query.scaladsl.ReadJournal specified by the given read journal configuration entry.
-
final
def
readJournalFor[T <: ReadJournal](readJournalPluginId: String, readJournalPluginConfig: Config): T
Scala API: Returns the akka.persistence.query.scaladsl.ReadJournal specified by the given read journal configuration entry.
Scala API: Returns the akka.persistence.query.scaladsl.ReadJournal specified by the given read journal configuration entry.
The provided readJournalPluginConfig will be used to configure the journal plugin instead of the actor system config.