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
Inherited Members
Namespace: Akka.Persistence.Journal
Assembly: Akka.Persistence.dll
Syntax
public class ReplayFilter : ActorBase, IInternalActor

Constructors

| Edit this page View Source

ReplayFilter(IActorRef, ReplayFilterMode, int, int, bool)

TBD

Declaration
public ReplayFilter(IActorRef persistentActor, ReplayFilterMode mode, int windowSize, int maxOldWriters, bool debugEnabled)
Parameters
Type Name Description
IActorRef persistentActor

TBD
ReplayFilterMode mode

TBD
int windowSize

TBD
int maxOldWriters

TBD
bool debugEnabled

TBD

Properties

| Edit this page View Source

DebugEnabled

TBD

Declaration
public bool DebugEnabled { get; }
Property Value
Type Description
bool
| Edit this page View Source

MaxOldWriters

TBD

Declaration
public int MaxOldWriters { get; }
Property Value
Type Description
int
| Edit this page View Source

Mode

TBD

Declaration
public ReplayFilterMode Mode { get; }
Property Value
Type Description
ReplayFilterMode
| Edit this page View Source

PersistentActor

TBD

Declaration
public IActorRef PersistentActor { get; }
Property Value
Type Description
IActorRef
| Edit this page View Source

WindowSize

TBD

Declaration
public int WindowSize { get; }
Property Value
Type Description
int

Methods

| Edit this page View Source

Props(IActorRef, ReplayFilterMode, int, int, bool)

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
int windowSize

TBD
int maxOldWriters

TBD
bool debugEnabled

TBD
Returns
Type Description
Props

TBD
Exceptions
Type Condition
ArgumentNullException

This exception is thrown for a number of reasons. These include:

  • The specified windowSize is less than or equal to zero.
  • The specified maxOldWriters is less than or equal to zero.
  • The specified mode is Disabled.
| Edit this page View Source

Receive(object)

TBD

Declaration
protected override bool Receive(object message)
Parameters
Type Name Description
object message

TBD
Returns
Type Description
bool

TBD
Overrides
Exceptions
Type Condition
ArgumentException

This exception is thrown when the Mode is set to Disabled.
IllegalStateException

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

Implements

Extension Methods