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.Add(IPersistentRepresentation)

MemoryJournal.Delete(string, long)

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

MemoryJournal.HighestSequenceNr(string)

MemoryJournal.ReceivePluginInternal(object)

AsyncWriteJournal.CanPublish

AsyncWriteJournal.CheckHealthAsync(CancellationToken)

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

Storage

Storage property for accessing journal data. Override in subclasses to share storage.

Declaration

protected override MemoryJournal.JournalStorage Storage { get; }

Property Value

Type	Description
MemoryJournal.JournalStorage

Overrides

MemoryJournal.Storage

Implements

IInternalActor

IAsyncRecovery

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(object)