akka.actor.dungeon
Interface DeathWatch

All Known Implementing Classes:

ActorCell, ResizablePoolCell, RoutedActorCell

public interface DeathWatch

Method Summary

void	addressTerminated(Address address)
void	addWatcher(ActorRef watchee, ActorRef watcher)
<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.
void	receivedTerminated(Terminated t)
scala.collection.immutable.Set<ActorRef>	removeFromSet(ActorRef subject, scala.collection.immutable.Set<ActorRef> set)
void	remWatcher(ActorRef watchee, ActorRef watcher)
void	subscribeAddressTerminated()
void	tellWatchersWeDied()
scala.collection.immutable.Set<ActorRef>	terminatedQueued()
void	terminatedQueuedFor(ActorRef subject)
void	unsubscribeAddressTerminated()
ActorRef	unwatch(ActorRef subject)
void	unwatchWatchedActors(Actor actor)
ActorRef	watch(ActorRef subject)
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.
scala.collection.immutable.Set<ActorRef>	watchedBy()
scala.collection.immutable.Set<ActorRef>	watching()
boolean	watchingContains(ActorRef subject)

Method Detail

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()