Class TestJournal

In-memory persistence journal implementation which behavior could be controlled by interceptors.

Inheritance
Object
ActorBase
WriteJournalBase
AsyncWriteJournal
MemoryJournal
TestJournal
Implements
Inherited Members
Namespace: Akka.Persistence.TestKit
Assembly: Akka.Persistence.TestKit.dll
Syntax
public sealed class TestJournal : MemoryJournal, IInternalActor, IAsyncRecovery

Methods

| Improve this Doc View Source

FromRef(IActorRef)

Create proxy object from journal actor reference which can alter behavior of journal.

Declaration
public static ITestJournal FromRef(IActorRef actor)
Parameters
Type Name Description
IActorRef actor

Journal actor reference.
Returns
Type Description
ITestJournal

Proxy object to control TestJournal.
Remarks

Journal actor must be of TestJournal type.

| Improve this Doc View Source

ReadHighestSequenceNrAsync(String, Int64)

Declaration
public override async Task<long> ReadHighestSequenceNrAsync(string persistenceId, long fromSequenceNr)
Parameters
Type Name Description
String persistenceId
Int64 fromSequenceNr
Returns
Type Description
Task<Int64>
Overrides
| Improve this Doc View Source

ReceivePluginInternal(Object)

Declaration
protected override bool ReceivePluginInternal(object message)
Parameters
Type Name Description
Object message
Returns
Type Description
Boolean
Overrides
| Improve this Doc View Source

ReplayMessagesAsync(IActorContext, String, Int64, Int64, Int64, Action<IPersistentRepresentation>)

Declaration
public override async Task ReplayMessagesAsync(IActorContext context, string persistenceId, long fromSequenceNr, long toSequenceNr, long max, Action<IPersistentRepresentation> recoveryCallback)
Parameters
Type Name Description
IActorContext context
String persistenceId
Int64 fromSequenceNr
Int64 toSequenceNr
Int64 max
Action<IPersistentRepresentation> recoveryCallback
Returns
Type Description
Task
Overrides
| Improve this Doc View Source

WriteMessagesAsync(IEnumerable<AtomicWrite>)

Declaration
protected override async Task<IImmutableList<Exception>> WriteMessagesAsync(IEnumerable<AtomicWrite> messages)
Parameters
Type Name Description
IEnumerable<AtomicWrite> messages
Returns
Type Description
Task<System.Collections.Immutable.IImmutableList<Exception>>
Overrides

Implements

Extension Methods