Package org.apache.pekko.actor.dungeon

Interface DeathWatch

public interface DeathWatch

  • Method Details

    • addWatcher

      void addWatcher(ActorRef watchee, ActorRef watcher)

    • addressTerminated

      void addressTerminated(Address address)

    • checkWatchingSame

      void checkWatchingSame(org.apache.pekko.actor.InternalActorRef ref, scala.Option<Object> newMessage)
      Call only if it was checked before that `watching contains ref`

    • isWatching

      boolean isWatching(ActorRef ref)

    • maintainAddressTerminatedSubscription

      <T> T maintainAddressTerminatedSubscription(ActorRef change, scala.Function0<T> block)
      Starts subscription to AddressTerminated if not already subscribing and the block adds a non-local ref to watching or watchedBy. Ends subscription to AddressTerminated if subscribing and the block removes the last non-local ref from watching and watchedBy.

    • maintainAddressTerminatedSubscription$default$1

      <T> ActorRef maintainAddressTerminatedSubscription$default$1()

    • receivedTerminated

      void receivedTerminated(Terminated t)

    • remWatcher

      void remWatcher(ActorRef watchee, ActorRef watcher)

    • subscribeAddressTerminated

      void subscribeAddressTerminated()

    • tellWatchersWeDied

      void tellWatchersWeDied()

    • terminatedQueuedFor

      void terminatedQueuedFor(ActorRef subject, scala.Option<Object> customMessage)

    • terminatedQueued_$eq

      void terminatedQueued_$eq(scala.collection.immutable.Map<ActorRef,scala.Option<Object>> x$1)

    • unsubscribeAddressTerminated

      void unsubscribeAddressTerminated()

    • unwatch

      ActorRef unwatch(ActorRef subject)

    • unwatchWatchedActors

      void unwatchWatchedActors(Actor actor)

    • updateWatching

      void updateWatching(org.apache.pekko.actor.InternalActorRef ref, scala.Option<Object> newMessage)

    • watch

      ActorRef watch(ActorRef subject)

    • watchWith

      ActorRef watchWith(ActorRef subject, Object msg)

    • watchedActorTerminated

      void watchedActorTerminated(ActorRef actor, boolean existenceConfirmed, boolean addressTerminated)
      When this actor is watching the subject of pekko.actor.Terminated message it will be propagated to user's receive.

    • watchedBy_$eq

      void watchedBy_$eq(scala.collection.immutable.Set<ActorRef> x$1)

    • watching_$eq

      void watching_$eq(scala.collection.immutable.Map<ActorRef,scala.Option<Object>> x$1)