Class PersistenceTestKitReadJournalProvider
- java.lang.Object
-
- org.apache.pekko.persistence.testkit.query.PersistenceTestKitReadJournalProvider
-
- All Implemented Interfaces:
ReadJournalProvider
public class PersistenceTestKitReadJournalProvider extends java.lang.Object implements ReadJournalProvider
-
-
Constructor Summary
Constructors Constructor Description PersistenceTestKitReadJournalProvider(ExtendedActorSystem system, com.typesafe.config.Config config, java.lang.String configPath)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description PersistenceTestKitReadJournal
javadslReadJournal()
TheReadJournal
implementation for the Java API.PersistenceTestKitReadJournal
scaladslReadJournal()
TheReadJournal
implementation for the Scala API.
-
-
-
Constructor Detail
-
PersistenceTestKitReadJournalProvider
public PersistenceTestKitReadJournalProvider(ExtendedActorSystem system, com.typesafe.config.Config config, java.lang.String configPath)
-
-
Method Detail
-
javadslReadJournal
public PersistenceTestKitReadJournal 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 PersistenceTestKitReadJournal 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
-
-