akka.persistence.journal

Class ReplayFilter$

java.lang.Object

akka.persistence.journal.ReplayFilter$

public class ReplayFilter$
extends java.lang.Object

INTERNAL API

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

Field Summary

Fields

Modifier and Type	Field and Description
static ReplayFilter$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
ReplayFilter$()

Method Summary

Modifier and Type	Method and Description
Props	props(ActorRef persistentActor, ReplayFilter.Mode mode, int windowSize, int maxOldWriters)
Props	props(ActorRef persistentActor, ReplayFilter.Mode mode, int windowSize, int maxOldWriters, boolean debugEnabled)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MODULE$

public static final ReplayFilter$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

ReplayFilter$

public ReplayFilter$()

Method Detail

props

public Props props(ActorRef persistentActor,
                   ReplayFilter.Mode mode,
                   int windowSize,
                   int maxOldWriters,
                   boolean debugEnabled)

props

public Props props(ActorRef persistentActor,
                   ReplayFilter.Mode mode,
                   int windowSize,
                   int maxOldWriters)