Class MemoryJournal

In-memory journal for testing purposes.

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

Properties

| Improve this Doc View Source

Messages

Declaration
protected virtual ConcurrentDictionary<string, LinkedList<IPersistentRepresentation>> Messages { get; }
Property Value
Type Description
ConcurrentDictionary<String, LinkedList<IPersistentRepresentation>>

Methods

| Improve this Doc View Source

Add(IPersistentRepresentation)

Declaration
public IDictionary<string, LinkedList<IPersistentRepresentation>> Add(IPersistentRepresentation persistent)
Parameters
Type Name Description
IPersistentRepresentation persistent
Returns
Type Description
IDictionary<String, LinkedList<IPersistentRepresentation>>
| Improve this Doc View Source

Delete(String, Int64)

Declaration
public IDictionary<string, LinkedList<IPersistentRepresentation>> Delete(string pid, long seqNr)
Parameters
Type Name Description
String pid
Int64 seqNr
Returns
Type Description
IDictionary<String, LinkedList<IPersistentRepresentation>>
| Improve this Doc View Source

DeleteMessagesToAsync(String, Int64)

Declaration
protected override Task DeleteMessagesToAsync(string persistenceId, long toSequenceNr)
Parameters
Type Name Description
String persistenceId
Int64 toSequenceNr
Returns
Type Description
Task
Overrides
| Improve this Doc View Source

HighestSequenceNr(String)

Declaration
public long HighestSequenceNr(string pid)
Parameters
Type Name Description
String pid
Returns
Type Description
Int64
| Improve this Doc View Source

Read(String, Int64, Int64, Int64)

Declaration
public IEnumerable<IPersistentRepresentation> Read(string pid, long fromSeqNr, long toSeqNr, long max)
Parameters
Type Name Description
String pid
Int64 fromSeqNr
Int64 toSeqNr
Int64 max
Returns
Type Description
IEnumerable<IPersistentRepresentation>
| Improve this Doc View Source

ReadHighestSequenceNrAsync(String, Int64)

Declaration
public override 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 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

Update(String, Int64, Func<IPersistentRepresentation, IPersistentRepresentation>)

Declaration
public IDictionary<string, LinkedList<IPersistentRepresentation>> Update(string pid, long seqNr, Func<IPersistentRepresentation, IPersistentRepresentation> updater)
Parameters
Type Name Description
String pid
Int64 seqNr
Func<IPersistentRepresentation, IPersistentRepresentation> updater
Returns
Type Description
IDictionary<String, LinkedList<IPersistentRepresentation>>
| Improve this Doc View Source

WriteMessagesAsync(IEnumerable<AtomicWrite>)

Declaration
protected override 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