Class WriteJournalBase

Base class for the journal persistence

Inheritance

object

ActorBase

WriteJournalBase

AsyncWriteJournal

Implements

IInternalActor

Inherited Members

ActorBase.Sender

ActorBase.Self

ActorBase.Context

ActorBase.AroundReceive(Receive, object)

ActorBase.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 abstract class WriteJournalBase : ActorBase, IInternalActor

Constructors

WriteJournalBase()

TBD

Declaration

protected WriteJournalBase()

Methods

AdaptToJournal(IPersistentRepresentation)

Apply any registered eventadapter to the data payload

Declaration

protected IPersistentRepresentation AdaptToJournal(IPersistentRepresentation representation)

Parameters

Type	Name	Description
IPersistentRepresentation	representation

Returns

Type	Description
IPersistentRepresentation

PreparePersistentBatch(IEnumerable<IPersistentEnvelope>)

Creates a sequence of write actions to be executed based on the given messages. Applies any registered EventAdapters to the payloads.

Declaration

protected IEnumerable<AtomicWrite> PreparePersistentBatch(IEnumerable<IPersistentEnvelope> resequenceables)

Parameters

Type	Name	Description
IEnumerable<IPersistentEnvelope>	resequenceables	list of messages to write

Returns

Type	Description
IEnumerable<AtomicWrite>

Implements

IInternalActor

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(object)