Class ReplayFilter

    • Constructor Detail

      • ReplayFilter

        public ReplayFilter​(ActorRef persistentActor,
                            ReplayFilter.Mode mode,
                            int windowSize,
                            int maxOldWriters,
                            boolean debugEnabled)
      • ReplayFilter

        public ReplayFilter​(ActorRef persistentActor,
                            ReplayFilter.Mode mode,
                            int windowSize,
                            int maxOldWriters)
    • Method Detail

      • props

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

        public ActorContext context()
        Description copied from interface: Actor
        Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such as forward.

        WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!

        ActorContext is the Scala API. getContext returns a AbstractActor.ActorContext, which is the Java API of the actor context.

        Specified by:
        context in interface Actor
      • self

        public final ActorRef self()
        Description copied from interface: Actor
        The 'self' field holds the ActorRef for this actor.

        Can be used to send messages to itself:
         self ! message
         
        Specified by:
        self in interface Actor
      • akka$actor$Actor$_setter_$context_$eq

        protected void akka$actor$Actor$_setter_$context_$eq​(ActorContext x$1)
        Description copied from interface: Actor
        Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such as forward.

        WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!

        ActorContext is the Scala API. getContext returns a AbstractActor.ActorContext, which is the Java API of the actor context.

        Specified by:
        akka$actor$Actor$_setter_$context_$eq in interface Actor
      • akka$actor$Actor$_setter_$self_$eq

        protected final void akka$actor$Actor$_setter_$self_$eq​(ActorRef x$1)
        Description copied from interface: Actor
        The 'self' field holds the ActorRef for this actor.

        Can be used to send messages to itself:
         self ! message
         
        Specified by:
        akka$actor$Actor$_setter_$self_$eq in interface Actor
      • oldWriters

        public scala.collection.mutable.LinkedHashSet<java.lang.String> oldWriters()
      • writerUuid

        public java.lang.String writerUuid()
      • writerUuid_$eq

        public void writerUuid_$eq​(java.lang.String x$1)
      • seqNo

        public long seqNo()
      • seqNo_$eq

        public void seqNo_$eq​(long x$1)
      • receive

        public scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receive()
        Description copied from interface: Actor
        Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.
        Specified by:
        receive in interface Actor
      • sendBuffered

        public void sendBuffered()
      • logIssue

        public void logIssue​(java.lang.String errMsg)
      • fail

        public void fail​(java.lang.IllegalStateException cause)