public class ReplayFilter
extends java.lang.Object
implements akka.actor.Actor, akka.actor.ActorLogging
Modifier and Type | Class and Description |
---|---|
static class |
ReplayFilter.Disabled$ |
static class |
ReplayFilter.Fail$ |
static interface |
ReplayFilter.Mode |
static class |
ReplayFilter.RepairByDiscardOld$ |
static class |
ReplayFilter.Warn$ |
Constructor and Description |
---|
ReplayFilter(akka.actor.ActorRef persistentActor,
ReplayFilter.Mode mode,
int windowSize,
int maxOldWriters) |
Modifier and Type | Method and Description |
---|---|
java.util.LinkedList<JournalProtocol.ReplayedMessage> |
buffer() |
void |
fail(java.lang.IllegalStateException cause) |
void |
logIssue(java.lang.String errMsg) |
scala.collection.mutable.LinkedHashSet<java.lang.String> |
oldWriters() |
static akka.actor.Props |
props(akka.actor.ActorRef persistentActor,
ReplayFilter.Mode mode,
int windowSize,
int maxOldWriters) |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive() |
void |
sendBuffered() |
long |
seqNo() |
java.lang.String |
writerUuid() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, postStop, preRestart, preStart, self, sender, supervisorStrategy, unhandled
public ReplayFilter(akka.actor.ActorRef persistentActor, ReplayFilter.Mode mode, int windowSize, int maxOldWriters)
public static akka.actor.Props props(akka.actor.ActorRef persistentActor, ReplayFilter.Mode mode, int windowSize, int maxOldWriters)
public java.util.LinkedList<JournalProtocol.ReplayedMessage> buffer()
public scala.collection.mutable.LinkedHashSet<java.lang.String> oldWriters()
public java.lang.String writerUuid()
public long seqNo()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
receive
in interface akka.actor.Actor
public void sendBuffered()
public void logIssue(java.lang.String errMsg)
public void fail(java.lang.IllegalStateException cause)