Class SharedMemoryJournal

Inheritance

object

ActorBase

WriteJournalBase

AsyncWriteJournal

MemoryJournal

SharedMemoryJournal

Implements

IInternalActor

IAsyncRecovery

Inherited Members

MemoryJournal.WriteMessagesAsync(IEnumerable<AtomicWrite>, CancellationToken)

MemoryJournal.ReadHighestSequenceNrAsync(string, long, CancellationToken)

MemoryJournal.ReplayMessagesAsync(IActorContext, string, long, long, long, Action<IPersistentRepresentation>)

MemoryJournal.DeleteMessagesToAsync(string, long, CancellationToken)

MemoryJournal.ReceivePluginInternal(object)

MemoryJournal.Add(IPersistentRepresentation)

MemoryJournal.Update(string, long, Func<IPersistentRepresentation, IPersistentRepresentation>)

MemoryJournal.Delete(string, long)

MemoryJournal.Read(string, long, long, long)

MemoryJournal.HighestSequenceNr(string)

AsyncWriteJournal.CanPublish

AsyncWriteJournal.Receive(object)

AsyncWriteJournal.ReceiveWriteJournal(object)

AsyncWriteJournal.TryUnwrapException(Exception)

WriteJournalBase.PreparePersistentBatch(IEnumerable<IPersistentEnvelope>)

WriteJournalBase.AdaptToJournal(IPersistentRepresentation)

ActorBase.Sender

ActorBase.Self

ActorBase.Context

ActorBase.AroundReceive(Receive, object)

ActorBase.EmptyReceive

ActorBase.Unhandled(object)

ActorBase.Become(Receive)

ActorBase.BecomeStacked(Receive)

ActorBase.UnbecomeStacked()

ActorBase.SetReceiveTimeout(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 SharedMemoryJournal : MemoryJournal, IInternalActor, IAsyncRecovery

Properties

Messages

Declaration

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

Property Value

Type	Description
ConcurrentDictionary<string, LinkedList<IPersistentRepresentation>>

Overrides

MemoryJournal.Messages

Implements

IInternalActor

IAsyncRecovery

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(object)