Class PersistentActor

Persistent actor - can be used to implement command or eventsourcing.

Inheritance

object

ActorBase

Eventsourced

PersistentActor

AtLeastOnceDeliveryActor

PersistentFSMBase<TState, TData, TEvent>

Implements

IInternalActor

IPersistentIdentity

IPersistenceStash

IWithUnboundedStash

IWithUnrestrictedStash

IActorStash

IRequiresMessageQueue<IUnboundedDequeBasedMessageQueueSemantics>

IPersistenceRecovery

Inherited Members

Eventsourced.Extension

Eventsourced.Log

Eventsourced.PersistenceId

Eventsourced.Recovery

Eventsourced.InternalStashOverflowStrategy

Eventsourced.Stash

Eventsourced.JournalPluginId

Eventsourced.SnapshotPluginId

Eventsourced.Journal

Eventsourced.SnapshotStore

Eventsourced.SnapshotterId

Eventsourced.IsRecovering

Eventsourced.IsRecoveryFinished

Eventsourced.LastSequenceNr

Eventsourced.SnapshotSequenceNr

Eventsourced.LoadSnapshot(string, SnapshotSelectionCriteria, long)

Eventsourced.SaveSnapshot(object)

Eventsourced.DeleteSnapshot(long)

Eventsourced.DeleteSnapshots(SnapshotSelectionCriteria)

Eventsourced.ReceiveRecover(object)

Eventsourced.ReceiveCommand(object)

Eventsourced.Persist<TEvent>(TEvent, Action<TEvent>)

Eventsourced.PersistAll<TEvent>(IEnumerable<TEvent>, Action<TEvent>)

Eventsourced.PersistAsync<TEvent>(TEvent, Action<TEvent>)

Eventsourced.PersistAllAsync<TEvent>(IEnumerable<TEvent>, Action<TEvent>)

Eventsourced.DeferAsync<TEvent>(TEvent, Action<TEvent>)

Eventsourced.DeleteMessages(long)

Eventsourced.OnReplaySuccess()

Eventsourced.OnRecoveryFailure(Exception, object)

Eventsourced.OnPersistFailure(Exception, object, long)

Eventsourced.OnPersistRejected(Exception, object, long)

Eventsourced.RunTask(Func<Task>)

Eventsourced.UnstashFilterPredicate

Eventsourced.AroundReceive(Receive, object)

Eventsourced.AroundPreStart()

Eventsourced.AroundPreRestart(Exception, object)

Eventsourced.AroundPostRestart(Exception, object)

Eventsourced.AroundPostStop()

Eventsourced.Unhandled(object)

ActorBase.Sender

ActorBase.Self

ActorBase.Context

ActorBase.EmptyReceive

ActorBase.Become(Receive)

ActorBase.BecomeStacked(Receive)

ActorBase.UnbecomeStacked()

ActorBase.SetReceiveTimeout(TimeSpan?)

ActorBase.PreStart()

ActorBase.PreRestart(Exception, object)

ActorBase.PostRestart(Exception)

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

Assembly: Akka.Persistence.dll

Syntax

public abstract class PersistentActor : Eventsourced, IInternalActor, IPersistentIdentity, IPersistenceStash, IWithUnboundedStash, IWithUnrestrictedStash, IActorStash, IRequiresMessageQueue<IUnboundedDequeBasedMessageQueueSemantics>, IPersistenceRecovery

Methods

Receive(object)

Processor for user defined messages.

Declaration

protected override bool Receive(object message)

Parameters

Type	Name	Description
object	message	The message.

Returns

Type	Description
bool	TBD

Overrides

ActorBase.Receive(object)

Implements

IInternalActor

IPersistentIdentity

IPersistenceStash

IWithUnboundedStash

IWithUnrestrictedStash

IActorStash

IRequiresMessageQueue<T>

IPersistenceRecovery

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(object)