Class SharedMemoryJournal

TBD

Inheritance

Object

ActorBase

WriteJournalBase

AsyncWriteJournal

MemoryJournal

SharedMemoryJournal

Implements

IInternalActor

IAsyncRecovery

Inherited Members

MemoryJournal.WriteMessagesAsync(IEnumerable<AtomicWrite>)

MemoryJournal.ReadHighestSequenceNrAsync(String, Int64)

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

MemoryJournal.DeleteMessagesToAsync(String, Int64)

MemoryJournal.ReceivePluginInternal(Object)

MemoryJournal.Add(IPersistentRepresentation)

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

MemoryJournal.Delete(String, Int64)

MemoryJournal.Read(String, Int64, Int64, Int64)

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

Properties

Messages

TBD

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)