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

| 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
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.
| 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
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