Class WriteJournalBase

TBD

Inheritance

Object

ActorBase

WriteJournalBase

AsyncWriteJournal

BatchingSqlJournal<TConnection, TCommand>

Implements

IInternalActor

Inherited Members

ActorBase.Sender

ActorBase.Self

ActorBase.IInternalActor.ActorContext

ActorBase.Context

ActorBase.AroundReceive(Receive, Object)

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

Constructors

WriteJournalBase()

TBD

Declaration

protected WriteJournalBase()

Methods

AdaptToJournal(IPersistentRepresentation)

INTERNAL API

Declaration

protected IPersistentRepresentation AdaptToJournal(IPersistentRepresentation representation)

Parameters

Type	Name	Description
IPersistentRepresentation	representation

Returns

Type	Description
IPersistentRepresentation

PreparePersistentBatch(IEnumerable<IPersistentEnvelope>)

TBD

Declaration

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

Parameters

Type	Name	Description
IEnumerable<IPersistentEnvelope>	resequenceables	TBD

Returns

Type	Description
IEnumerable<AtomicWrite>	TBD

Implements

IInternalActor

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(Object)