Package akka.persistence.query
Interface ReadJournalProvider
-
- All Known Implementing Classes:
LeveldbReadJournalProvider
,PersistenceTestKitReadJournalProvider
public interface ReadJournalProvider
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
andakka.persistence.query.javadsl.ReadJournal
. The plugin must implement both thescaladsl
and thejavadsl
traits because theakka.stream.scaladsl.Source
andakka.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 ScalaSource
directly. One of the implementations can delegate to the other.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description ReadJournal
javadslReadJournal()
TheReadJournal
implementation for the Java API.ReadJournal
scaladslReadJournal()
TheReadJournal
implementation for the Scala API.
-
-
-
Method Detail
-
javadslReadJournal
ReadJournal javadslReadJournal()
TheReadJournal
implementation for the Java API. This corresponds to the instance that is returned byPersistenceQuery.getReadJournalFor(java.lang.Class<T>, java.lang.String, com.typesafe.config.Config)
.
-
scaladslReadJournal
ReadJournal scaladslReadJournal()
TheReadJournal
implementation for the Scala API. This corresponds to the instance that is returned byPersistenceQuery.readJournalFor(java.lang.String, com.typesafe.config.Config)
.
-
-