akka.actor.dungeon
Interface DeathWatch
- All Known Implementing Classes:
- ActorCell, ResizablePoolCell, RoutedActorCell
public interface DeathWatch
watching
scala.collection.immutable.Set<ActorRef> watching()
watchedBy
scala.collection.immutable.Set<ActorRef> watchedBy()
terminatedQueued
scala.collection.immutable.Set<ActorRef> terminatedQueued()
watch
ActorRef watch(ActorRef subject)
unwatch
ActorRef unwatch(ActorRef subject)
receivedTerminated
void receivedTerminated(Terminated t)
watchedActorTerminated
void watchedActorTerminated(ActorRef actor,
boolean existenceConfirmed,
boolean addressTerminated)
- When this actor is watching the subject of
Terminated
message
it will be propagated to user's receive.
- Parameters:
actor
- (undocumented)existenceConfirmed
- (undocumented)addressTerminated
- (undocumented)
terminatedQueuedFor
void terminatedQueuedFor(ActorRef subject)
watchingContains
boolean watchingContains(ActorRef subject)
removeFromSet
scala.collection.immutable.Set<ActorRef> removeFromSet(ActorRef subject,
scala.collection.immutable.Set<ActorRef> set)
tellWatchersWeDied
void tellWatchersWeDied()
unwatchWatchedActors
void unwatchWatchedActors(Actor actor)
addWatcher
void addWatcher(ActorRef watchee,
ActorRef watcher)
remWatcher
void remWatcher(ActorRef watchee,
ActorRef watcher)
addressTerminated
void addressTerminated(Address address)
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.
- Parameters:
change
- (undocumented)block
- (undocumented)
- Returns:
- (undocumented)
unsubscribeAddressTerminated
void unsubscribeAddressTerminated()
subscribeAddressTerminated
void subscribeAddressTerminated()