Package akka.persistence.query
Interface ReadJournalProvider
-
- All Known Implementing Classes:
EventsBySliceFirehoseReadJournalProvider,LeveldbReadJournalProvider,PersistenceTestKitReadJournalProvider
public interface ReadJournalProviderA 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.ReadJournalandakka.persistence.query.javadsl.ReadJournal. The plugin must implement both thescaladsland thejavadsltraits because theakka.stream.scaladsl.Sourceandakka.stream.javadsl.Sourceare 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 ScalaSourcedirectly. One of the implementations can delegate to the other.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description ReadJournaljavadslReadJournal()TheReadJournalimplementation for the Java API.ReadJournalscaladslReadJournal()TheReadJournalimplementation for the Scala API.
-
-
-
Method Detail
-
javadslReadJournal
ReadJournal javadslReadJournal()
TheReadJournalimplementation 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()
TheReadJournalimplementation for the Scala API. This corresponds to the instance that is returned byPersistenceQuery.readJournalFor(java.lang.String, com.typesafe.config.Config).
-
-