Class ReplayFilter

Detect corrupt event stream during replay. It uses the WriterGuid and the SequenceNr in the replayed events to find events emitted by overlapping writers.

Inheritance

Object

ActorBase

ReplayFilter

Implements

IInternalActor

Inherited Members

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()

Namespace: Akka.Persistence.Journal

Assembly: Akka.Persistence.dll

Syntax

public class ReplayFilter : ActorBase, IInternalActor

Constructors

| Improve this Doc View Source

ReplayFilter(IActorRef, ReplayFilterMode, Int32, Int32, Boolean)

TBD

Declaration

public ReplayFilter(IActorRef persistentActor, ReplayFilterMode mode, int windowSize, int maxOldWriters, bool debugEnabled)

Parameters

Type	Name	Description
IActorRef	persistentActor	TBD
ReplayFilterMode	mode	TBD
Int32	windowSize	TBD
Int32	maxOldWriters	TBD
Boolean	debugEnabled	TBD

Properties

| Improve this Doc View Source

DebugEnabled

TBD

Declaration

public bool DebugEnabled { get; }

Property Value

Type	Description
Boolean

| Improve this Doc View Source

MaxOldWriters

TBD

Declaration

public int MaxOldWriters { get; }

Property Value

Type	Description
Int32

| Improve this Doc View Source

Mode

TBD

Declaration

public ReplayFilterMode Mode { get; }

Property Value

Type	Description
ReplayFilterMode

| Improve this Doc View Source

PersistentActor

TBD

Declaration

public IActorRef PersistentActor { get; }

Property Value

Type	Description
IActorRef

| Improve this Doc View Source

WindowSize

TBD

Declaration

public int WindowSize { get; }

Property Value

Type	Description
Int32

Methods

| Improve this Doc View Source

Props(IActorRef, ReplayFilterMode, Int32, Int32, Boolean)

TBD

Declaration

public static Props Props(IActorRef persistentActor, ReplayFilterMode mode, int windowSize, int maxOldWriters, bool debugEnabled)

Parameters

Type	Name	Description
IActorRef	persistentActor	TBD
ReplayFilterMode	mode	TBD
Int32	windowSize	TBD
Int32	maxOldWriters	TBD
Boolean	debugEnabled	TBD

Returns

Type	Description
Props	TBD

| Improve this Doc View Source

Receive(Object)

TBD

Declaration

protected override bool Receive(object message)

Parameters

Type	Name	Description
Object	message	TBD

Returns

Type	Description
Boolean	TBD

Exceptions

Type	Condition
IllegalStateException	This exception is thrown when either the replayed event is in the wrong order or from an old writer.

Implements

IInternalActor

Extension Methods

PatternMatch.Match(Object)

PatternMatch.Match<T>(Object)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(Object)

ObjectExtensions.IsDefaultForType<T>(T)