Package org.apache.pekko.persistence.testkit.scaladsl

Class PersistenceTestKit

java.lang.Object

org.apache.pekko.persistence.testkit.scaladsl.PersistenceTestKit

All Implemented Interfaces:

ClearOps, ClearPreservingSeqNums, CommonTestKitOps<PersistentRepr,JournalOperation>, ExpectOps<PersistentRepr>, HasStorage<JournalOperation,PersistentRepr>, PersistenceTestKitOps<PersistentRepr,JournalOperation>, PolicyOpsTestKit<JournalOperation>, RejectSupport<JournalOperation>

public class PersistenceTestKit
extends Object
implements PersistenceTestKitOps<PersistentRepr,JournalOperation>, ExpectOps<PersistentRepr>, HasStorage<JournalOperation,PersistentRepr>

Class for testing events of persistent actors.

NOTE! ActorSystem must be configured with PersistenceTestKitPlugin. The configuration can be retrieved with PersistenceTestKitPlugin.config.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PersistenceTestKit.Settings
static class	PersistenceTestKit.Settings$

Constructor Summary

Constructors

Constructor	Description
PersistenceTestKit(ActorSystem system)

Method Summary

Modifier and Type	Method	Description
static PersistenceTestKit	apply(ClassicActorSystemProvider system)
void	failNextNDeletes(int n, Throwable cause)	Fail next n delete from storage attempts with cause exception for any persistence id.
void	failNextNDeletes(String persistenceId, int n, Throwable cause)	Fail next n delete from storage attempts with cause exception for particular persistence id.
void	failNextNPersisted(int n, Throwable cause)	Fail next n write operations with the cause exception for any persistence id.
void	failNextNPersisted(String persistenceId, int n, Throwable cause)	Fail next n write operations with the cause exception for particular persistence id.
void	failNextNReads(int n, Throwable cause)	Fail next n read from storage (recovery) attempts with cause exception for any persistence id.
void	failNextNReads(String persistenceId, int n, Throwable cause)	Fail next n read from storage (recovery) attempts with cause exception for particular persistence id.
scala.collection.immutable.Seq<Object>	persistedInStorage(String persistenceId)	Retrieve all snapshots saved in storage by persistence id.
void	persistForRecovery(String persistenceId, scala.collection.immutable.Seq<Object> events)	Persist snapshots into storage in order.
void	rejectNextNDeletes(int n, Throwable cause)	Reject next n delete from storage operations for any persistence id with cause exception.
void	rejectNextNDeletes(String persistenceId, int n, Throwable cause)	Reject next n delete from storage operations for particular persistence id with cause exception.
void	rejectNextNPersisted(int n, Throwable cause)	Reject next n save in storage operations for any persistence id with cause exception.
void	rejectNextNPersisted(String persistenceId, int n, Throwable cause)	Reject next n save in storage operations for particular persistence id with cause exception.
void	rejectNextNReads(int n, Throwable cause)	Reject next n read from storage operations for any persistence id with cause exception.
void	rejectNextNReads(String persistenceId, int n, Throwable cause)	Reject next n read from storage operations for particular persistence id with cause exception.
protected EventStorage	storage()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.pekko.persistence.testkit.scaladsl.ClearOps

clearAll, clearByPersistenceId

Methods inherited from interface org.apache.pekko.persistence.testkit.scaladsl.ClearPreservingSeqNums

clearAllPreservingSeqNumbers, clearByIdPreservingSeqNumbers

Methods inherited from interface org.apache.pekko.persistence.testkit.scaladsl.CommonTestKitOps

expectNextPersisted, expectNextPersisted, expectNothingPersisted, expectNothingPersisted, failNextDelete, failNextDelete, failNextDelete, failNextDelete, failNextNDeletes, failNextNDeletes, failNextNPersisted, failNextNPersisted, failNextNReads, failNextNReads, failNextPersisted, failNextPersisted, failNextPersisted, failNextPersisted, failNextRead, failNextRead, failNextRead, failNextRead

Methods inherited from interface org.apache.pekko.persistence.testkit.scaladsl.ExpectOps

expectNextPersisted, expectNextPersisted, expectNextPersistedClass, expectNextPersistedClass, expectNextPersistedType, expectNextPersistedType, expectNothingPersisted, expectNothingPersisted, getItem, receivePersisted, receivePersisted, receivePersisted, receivePersisted

Methods inherited from interface org.apache.pekko.persistence.testkit.scaladsl.HasStorage

addToIndex, clearIndexStorage, nextIndex, nextIndexByPersistenceId_$eq, removeLastIndex, setIndex

Methods inherited from interface org.apache.pekko.persistence.testkit.scaladsl.PersistenceTestKitOps

rejectNextDelete, rejectNextDelete, rejectNextDelete, rejectNextDelete, rejectNextNDeletes, rejectNextNDeletes, rejectNextNPersisted, rejectNextNPersisted, rejectNextNReads, rejectNextNReads, rejectNextPersisted, rejectNextPersisted, rejectNextPersisted, rejectNextPersisted, rejectNextRead, rejectNextRead, rejectNextRead, rejectNextRead

Methods inherited from interface org.apache.pekko.persistence.testkit.scaladsl.PolicyOpsTestKit

failNextNOps, failNextNOps, failNextNOpsCond, failNextNOpsCond, resetPolicy, withPolicy

Methods inherited from interface org.apache.pekko.persistence.testkit.scaladsl.RejectSupport

rejectNextNOps, rejectNextNOps, rejectNextNOpsCond, rejectNextNOpsCond

Constructor Details

PersistenceTestKit

public PersistenceTestKit(ActorSystem system)

Method Details

apply

public static PersistenceTestKit apply(ClassicActorSystemProvider system)

storage

protected EventStorage storage()

Specified by:

storage in interface HasStorage<JournalOperation,PersistentRepr>

rejectNextNPersisted

public void rejectNextNPersisted(String persistenceId,
 int n,
 Throwable cause)

Description copied from interface: PersistenceTestKitOps

Reject next n save in storage operations for particular persistence id with cause exception.

Specified by:

rejectNextNPersisted in interface PersistenceTestKitOps<PersistentRepr,JournalOperation>

rejectNextNPersisted

public void rejectNextNPersisted(int n,
 Throwable cause)

Description copied from interface: PersistenceTestKitOps

Reject next n save in storage operations for any persistence id with cause exception.

Specified by:

rejectNextNPersisted in interface PersistenceTestKitOps<PersistentRepr,JournalOperation>

rejectNextNReads

public void rejectNextNReads(int n,
 Throwable cause)

Description copied from interface: PersistenceTestKitOps

Reject next n read from storage operations for any persistence id with cause exception.

Specified by:

rejectNextNReads in interface PersistenceTestKitOps<PersistentRepr,JournalOperation>

rejectNextNReads

public void rejectNextNReads(String persistenceId,
 int n,
 Throwable cause)

Description copied from interface: PersistenceTestKitOps

Reject next n read from storage operations for particular persistence id with cause exception.

Specified by:

rejectNextNReads in interface PersistenceTestKitOps<PersistentRepr,JournalOperation>

rejectNextNDeletes

public void rejectNextNDeletes(int n,
 Throwable cause)

Description copied from interface: PersistenceTestKitOps

Reject next n delete from storage operations for any persistence id with cause exception.

Specified by:

rejectNextNDeletes in interface PersistenceTestKitOps<PersistentRepr,JournalOperation>

rejectNextNDeletes

public void rejectNextNDeletes(String persistenceId,
 int n,
 Throwable cause)

Description copied from interface: PersistenceTestKitOps

Reject next n delete from storage operations for particular persistence id with cause exception.

Specified by:

rejectNextNDeletes in interface PersistenceTestKitOps<PersistentRepr,JournalOperation>

failNextNPersisted

public void failNextNPersisted(String persistenceId,
 int n,
 Throwable cause)

Description copied from interface: CommonTestKitOps

Fail next n write operations with the cause exception for particular persistence id.

Specified by:

failNextNPersisted in interface CommonTestKitOps<PersistentRepr,JournalOperation>

failNextNPersisted

public void failNextNPersisted(int n,
 Throwable cause)

Description copied from interface: CommonTestKitOps

Fail next n write operations with the cause exception for any persistence id.

Specified by:

failNextNPersisted in interface CommonTestKitOps<PersistentRepr,JournalOperation>

failNextNReads

public void failNextNReads(int n,
 Throwable cause)

Description copied from interface: CommonTestKitOps

Fail next n read from storage (recovery) attempts with cause exception for any persistence id.

Specified by:

failNextNReads in interface CommonTestKitOps<PersistentRepr,JournalOperation>

failNextNReads

public void failNextNReads(String persistenceId,
 int n,
 Throwable cause)

Description copied from interface: CommonTestKitOps

Fail next n read from storage (recovery) attempts with cause exception for particular persistence id.

Specified by:

failNextNReads in interface CommonTestKitOps<PersistentRepr,JournalOperation>

failNextNDeletes

public void failNextNDeletes(int n,
 Throwable cause)

Description copied from interface: CommonTestKitOps

Fail next n delete from storage attempts with cause exception for any persistence id.

Specified by:

failNextNDeletes in interface CommonTestKitOps<PersistentRepr,JournalOperation>

failNextNDeletes

public void failNextNDeletes(String persistenceId,
 int n,
 Throwable cause)

Description copied from interface: CommonTestKitOps

Fail next n delete from storage attempts with cause exception for particular persistence id.

Specified by:

failNextNDeletes in interface CommonTestKitOps<PersistentRepr,JournalOperation>

persistForRecovery

public void persistForRecovery(String persistenceId,
 scala.collection.immutable.Seq<Object> events)

Description copied from interface: PersistenceTestKitOps

Persist snapshots into storage in order.

Specified by:

persistForRecovery in interface PersistenceTestKitOps<PersistentRepr,JournalOperation>

persistedInStorage

public scala.collection.immutable.Seq<Object> persistedInStorage(String persistenceId)

Description copied from interface: PersistenceTestKitOps

Retrieve all snapshots saved in storage by persistence id.

Specified by:

persistedInStorage in interface PersistenceTestKitOps<PersistentRepr,JournalOperation>