akka.remote
Class RemoteDeploymentWatcher

java.lang.Object
  akka.remote.RemoteDeploymentWatcher

All Implemented Interfaces:

Actor, RequiresMessageQueue<UnboundedMessageQueueSemantics>

public class RemoteDeploymentWatcher
extends java.lang.Object
implements Actor, RequiresMessageQueue<UnboundedMessageQueueSemantics>

INTERNAL API

Responsible for cleaning up child references of remote deployed actors when remote node goes down (jvm crash, network failure), i.e. triggered by AddressTerminated.

Nested Class Summary

static class	RemoteDeploymentWatcher.WatchRemote
static class	RemoteDeploymentWatcher.WatchRemote$

Nested classes/interfaces inherited from interface akka.actor.Actor

Actor.emptyBehavior$

Constructor Summary

RemoteDeploymentWatcher()

Method Summary

scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	receive() This defines the initial actor behavior, it must return a partial function with the actor logic.
scala.collection.immutable.Map<ActorRef,InternalActorRef>	supervisors()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface akka.actor.Actor

aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, postStop, preRestart, preStart, self, sender, supervisorStrategy, unhandled

Constructor Detail

RemoteDeploymentWatcher

public RemoteDeploymentWatcher()

Method Detail

supervisors

public scala.collection.immutable.Map<ActorRef,InternalActorRef> supervisors()

receive

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

Description copied from interface: Actor

This defines the initial actor behavior, it must return a partial function with the actor logic.

Specified by:

receive in interface Actor

Returns:

(undocumented)