Class MemoryJournal

In-memory journal for testing purposes.

Inheritance

Object

ActorBase

WriteJournalBase

AsyncWriteJournal

MemoryJournal

SharedMemoryJournal

TestJournal

Implements

IInternalActor

IAsyncRecovery

Inherited Members

AsyncWriteJournal.CanPublish

AsyncWriteJournal.Receive(Object)

AsyncWriteJournal.ReceiveWriteJournal(Object)

AsyncWriteJournal.TryUnwrapException(Exception)

WriteJournalBase.PreparePersistentBatch(IEnumerable<IPersistentEnvelope>)

WriteJournalBase.AdaptToJournal(IPersistentRepresentation)

ActorBase.Sender

ActorBase.Self

ActorBase.IInternalActor.ActorContext

ActorBase.Context

ActorBase.AroundReceive(Receive, Object)

ActorBase.EmptyReceive

ActorBase.Unhandled(Object)

ActorBase.Become(Receive)

ActorBase.BecomeStacked(Receive)

ActorBase.UnbecomeStacked()

ActorBase.SetReceiveTimeout(Nullable<TimeSpan>)

ActorBase.AroundPreRestart(Exception, Object)

ActorBase.AroundPreStart()

ActorBase.PreStart()

ActorBase.AroundPostRestart(Exception, Object)

ActorBase.PreRestart(Exception, Object)

ActorBase.PostRestart(Exception)

ActorBase.AroundPostStop()

ActorBase.PostStop()

ActorBase.SupervisorStrategy()

Object.Equals(Object)

Object.Equals(Object, Object)

Object.GetHashCode()

Object.GetType()

Object.MemberwiseClone()

Object.ReferenceEquals(Object, Object)

Object.ToString()

Namespace: Akka.Persistence.Journal

Assembly: Akka.Persistence.dll

Syntax

public class MemoryJournal : AsyncWriteJournal, IInternalActor, IAsyncRecovery

Properties

Messages

TBD

Declaration

protected virtual ConcurrentDictionary<string, LinkedList<IPersistentRepresentation>> Messages { get; }

Property Value

Type	Description
ConcurrentDictionary<String, LinkedList<IPersistentRepresentation>>

Methods

Add(IPersistentRepresentation)

TBD

Declaration

public IDictionary<string, LinkedList<IPersistentRepresentation>> Add(IPersistentRepresentation persistent)

Parameters

Type	Name	Description
IPersistentRepresentation	persistent	TBD

Returns

Type	Description
IDictionary<String, LinkedList<IPersistentRepresentation>>	TBD

Delete(String, Int64)

TBD

Declaration

public IDictionary<string, LinkedList<IPersistentRepresentation>> Delete(string pid, long seqNr)

Parameters

Type	Name	Description
String	pid	TBD
Int64	seqNr	TBD

Returns

Type	Description
IDictionary<String, LinkedList<IPersistentRepresentation>>	TBD

DeleteMessagesToAsync(String, Int64)

TBD

Declaration

protected override Task DeleteMessagesToAsync(string persistenceId, long toSequenceNr)

Parameters

Type	Name	Description
String	persistenceId	TBD
Int64	toSequenceNr	TBD

Returns

Type	Description
Task	TBD

Overrides

AsyncWriteJournal.DeleteMessagesToAsync(String, Int64)

HighestSequenceNr(String)

TBD

Declaration

public long HighestSequenceNr(string pid)

Parameters

Type	Name	Description
String	pid	TBD

Returns

Type	Description
Int64	TBD

Read(String, Int64, Int64, Int64)

TBD

Declaration

public IEnumerable<IPersistentRepresentation> Read(string pid, long fromSeqNr, long toSeqNr, long max)

Parameters

Type	Name	Description
String	pid	TBD
Int64	fromSeqNr	TBD
Int64	toSeqNr	TBD
Int64	max	TBD

Returns

Type	Description
IEnumerable<IPersistentRepresentation>	TBD

ReadHighestSequenceNrAsync(String, Int64)

TBD

Declaration

public override Task<long> ReadHighestSequenceNrAsync(string persistenceId, long fromSequenceNr)

Parameters

Type	Name	Description
String	persistenceId	TBD
Int64	fromSequenceNr	TBD

Returns

Type	Description
Task<Int64>	TBD

Overrides

AsyncWriteJournal.ReadHighestSequenceNrAsync(String, Int64)

ReceivePluginInternal(Object)

Declaration

protected override bool ReceivePluginInternal(object message)

Parameters

Type	Name	Description
Object	message

Returns

Type	Description
Boolean

Overrides

AsyncWriteJournal.ReceivePluginInternal(Object)

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

TBD

Declaration

public override Task ReplayMessagesAsync(IActorContext context, string persistenceId, long fromSequenceNr, long toSequenceNr, long max, Action<IPersistentRepresentation> recoveryCallback)

Parameters

Type	Name	Description
IActorContext	context	TBD
String	persistenceId	TBD
Int64	fromSequenceNr	TBD
Int64	toSequenceNr	TBD
Int64	max	TBD
Action<IPersistentRepresentation>	recoveryCallback	TBD

Returns

Type	Description
Task	TBD

Overrides

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

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

TBD

Declaration

public IDictionary<string, LinkedList<IPersistentRepresentation>> Update(string pid, long seqNr, Func<IPersistentRepresentation, IPersistentRepresentation> updater)

Parameters

Type	Name	Description
String	pid	TBD
Int64	seqNr	TBD
Func<IPersistentRepresentation, IPersistentRepresentation>	updater	TBD

Returns

Type	Description
IDictionary<String, LinkedList<IPersistentRepresentation>>	TBD

WriteMessagesAsync(IEnumerable<AtomicWrite>)

TBD

Declaration

protected override Task<IImmutableList<Exception>> WriteMessagesAsync(IEnumerable<AtomicWrite> messages)

Parameters

Type	Name	Description
IEnumerable<AtomicWrite>	messages	TBD

Returns

Type	Description
Task<System.Collections.Immutable.IImmutableList<Exception>>	TBD

Overrides

AsyncWriteJournal.WriteMessagesAsync(IEnumerable<AtomicWrite>)

Implements

IInternalActor

IAsyncRecovery

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(Object)