Package akka.remote

Class ReliableDeliverySupervisor

    • Method Detail

      • 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
        Returns:
        (undocumented)
      • 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
        Returns:
        (undocumented)
      • 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
        Parameters:
        x$1 - (undocumented)
      • localAddress

        public Address localAddress()
      • remoteAddress

        public Address remoteAddress()
      • refuseUid

        public scala.Option<java.lang.Object> refuseUid()
      • autoResendTimer

        public Cancellable autoResendTimer()
      • supervisorStrategy

        public OneForOneStrategy supervisorStrategy()
        Description copied from interface: Actor
        User overridable definition the strategy to use for supervising child actors.
        Specified by:
        supervisorStrategy in interface Actor
        Returns:
        (undocumented)
      • currentHandle_$eq

        public void currentHandle_$eq​(scala.Option<AkkaProtocolHandle> x$1)
      • seqCounter

        public long seqCounter()
      • seqCounter_$eq

        public void seqCounter_$eq​(long x$1)
      • reset

        public void reset()
      • nextSeq

        public SeqNo nextSeq()
      • writer_$eq

        public void writer_$eq​(ActorRef x$1)
      • uid

        public scala.Option<java.lang.Object> uid()
      • uid_$eq

        public void uid_$eq​(scala.Option<java.lang.Object> x$1)
      • bailoutAt

        public scala.Option<scala.concurrent.duration.Deadline> bailoutAt()
      • bailoutAt_$eq

        public void bailoutAt_$eq​(scala.Option<scala.concurrent.duration.Deadline> x$1)
      • maxSilenceTimer

        public scala.Option<Cancellable> maxSilenceTimer()
      • maxSilenceTimer_$eq

        public void maxSilenceTimer_$eq​(scala.Option<Cancellable> x$1)
      • uidConfirmed

        public boolean uidConfirmed()
      • uidConfirmed_$eq

        public void uidConfirmed_$eq​(boolean x$1)
      • postStop

        public void postStop()
        Description copied from interface: Actor
        User overridable callback.

        Is called asynchronously after 'actor.stop()' is invoked. Empty default implementation.
        Specified by:
        postStop in interface Actor
      • postRestart

        public void postRestart​(java.lang.Throwable reason)
        Description copied from interface: Actor
        User overridable callback: By default it calls preStart().
        Specified by:
        postRestart in interface Actor
        Parameters:
        reason - the Throwable that caused the restart to happen

        Is called right AFTER restart on the newly created Actor to allow reinitialization after an Actor crash.
      • 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
        Returns:
        (undocumented)
      • gated

        public scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> gated​(boolean writerTerminated,
                                                                                           boolean earlyUngateRequested)
      • idle

        public scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> idle()
      • flushWait

        public scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> flushWait()