Package akka.persistence.query.typed
Class EventsBySliceFirehoseReadJournalProvider
- java.lang.Object
-
- akka.persistence.query.typed.EventsBySliceFirehoseReadJournalProvider
-
- All Implemented Interfaces:
ReadJournalProvider
public final class EventsBySliceFirehoseReadJournalProvider extends java.lang.Object implements ReadJournalProvider
-
-
Constructor Summary
Constructors Constructor Description EventsBySliceFirehoseReadJournalProvider(ExtendedActorSystem system, com.typesafe.config.Config config, java.lang.String cfgPath)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description EventsBySliceFirehoseQuery
javadslReadJournal()
TheReadJournal
implementation for the Java API.EventsBySliceFirehoseQuery
scaladslReadJournal()
TheReadJournal
implementation for the Scala API.
-
-
-
Constructor Detail
-
EventsBySliceFirehoseReadJournalProvider
public EventsBySliceFirehoseReadJournalProvider(ExtendedActorSystem system, com.typesafe.config.Config config, java.lang.String cfgPath)
-
-
Method Detail
-
javadslReadJournal
public EventsBySliceFirehoseQuery javadslReadJournal()
Description copied from interface:ReadJournalProvider
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)
.- Specified by:
javadslReadJournal
in interfaceReadJournalProvider
-
scaladslReadJournal
public EventsBySliceFirehoseQuery scaladslReadJournal()
Description copied from interface:ReadJournalProvider
TheReadJournal
implementation for the Scala API. This corresponds to the instance that is returned byPersistenceQuery.readJournalFor(java.lang.String, com.typesafe.config.Config)
.- Specified by:
scaladslReadJournal
in interfaceReadJournalProvider
-
-