trait ReadJournalProvider extends AnyRef
A query plugin must implement a class that implements this trait. It provides the concrete implementations for the Java and Scala APIs.
A read journal plugin must provide implementations for both
akka.persistence.query.scaladsl.ReadJournal
and akka.persistence.query.javaadsl.ReadJournal
.
The plugin must implement both the scaladsl
and the javadsl
traits because the
akka.stream.scaladsl.Source
and akka.stream.javadsl.Source
are different types
and even though those types can easily be converted to each other it is most convenient
for the end user to get access to the Java or Scala Source
directly.
One of the implementations can delegate to the other.
- Alphabetic
- By Inheritance
- ReadJournalProvider
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Abstract Value Members
-
abstract
def
javadslReadJournal(): ReadJournal
The
ReadJournal
implementation for the Java API.The
ReadJournal
implementation for the Java API. This corresponds to the instance that is returned by PersistenceQuery#getReadJournalFor. -
abstract
def
scaladslReadJournal(): ReadJournal
The
ReadJournal
implementation for the Scala API.The
ReadJournal
implementation for the Scala API. This corresponds to the instance that is returned by PersistenceQuery#readJournalFor.