public interface DeathWatch
Modifier and Type | Method and Description |
---|---|
void |
addressTerminated(Address address) |
void |
addWatcher(ActorRef watchee,
ActorRef watcher) |
boolean |
isWatching(ActorRef ref) |
<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() |
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. |
boolean |
watchingContains(ActorRef subject) |
boolean isWatching(ActorRef ref)
void receivedTerminated(Terminated t)
void watchedActorTerminated(ActorRef actor, boolean existenceConfirmed, boolean addressTerminated)
Terminated
message
it will be propagated to user's receive.actor
- (undocumented)existenceConfirmed
- (undocumented)addressTerminated
- (undocumented)void terminatedQueuedFor(ActorRef subject)
boolean watchingContains(ActorRef subject)
scala.collection.immutable.Set<ActorRef> removeFromSet(ActorRef subject, scala.collection.immutable.Set<ActorRef> set)
void tellWatchersWeDied()
void unwatchWatchedActors(Actor actor)
void addressTerminated(Address address)
<T> T maintainAddressTerminatedSubscription(ActorRef change, scala.Function0<T> block)
change
- (undocumented)block
- (undocumented)void unsubscribeAddressTerminated()
void subscribeAddressTerminated()