Package org.apache.pekko.persistence.testkit.query

Class PersistenceTestKitReadJournalProvider

java.lang.Object

org.apache.pekko.persistence.testkit.query.PersistenceTestKitReadJournalProvider

All Implemented Interfaces:

ReadJournalProvider

public class PersistenceTestKitReadJournalProvider
extends Object
implements ReadJournalProvider

Constructor Summary

Constructors

Constructor	Description
PersistenceTestKitReadJournalProvider(ExtendedActorSystem system, com.typesafe.config.Config config, String configPath)

Method Summary

Modifier and Type	Method	Description
PersistenceTestKitReadJournal	javadslReadJournal()	The ReadJournal implementation for the Java API.
PersistenceTestKitReadJournal	scaladslReadJournal()	The ReadJournal implementation for the Scala API.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

PersistenceTestKitReadJournalProvider

public PersistenceTestKitReadJournalProvider(ExtendedActorSystem system,
 com.typesafe.config.Config config,
 String configPath)

Method Details

javadslReadJournal

public PersistenceTestKitReadJournal javadslReadJournal()

Description copied from interface: ReadJournalProvider

The ReadJournal implementation for the Java API. This corresponds to the instance that is returned by PersistenceQuery.getReadJournalFor(java.lang.Class<T>, java.lang.String, com.typesafe.config.Config).

Specified by:

javadslReadJournal in interface ReadJournalProvider

scaladslReadJournal

public PersistenceTestKitReadJournal scaladslReadJournal()

Description copied from interface: ReadJournalProvider

The ReadJournal implementation for the Scala API. This corresponds to the instance that is returned by PersistenceQuery.readJournalFor(java.lang.String, com.typesafe.config.Config).

Specified by:

scaladslReadJournal in interface ReadJournalProvider