akka.remote
Class RemoteDeploymentWatcher

java.lang.Object
  akka.remote.RemoteDeploymentWatcher

All Implemented Interfaces:

akka.actor.Actor, akka.dispatch.RequiresMessageQueue<akka.dispatch.UnboundedMessageQueueSemantics>

public class RemoteDeploymentWatcher
extends java.lang.Object
implements akka.actor.Actor, akka.dispatch.RequiresMessageQueue<akka.dispatch.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

akka.actor.Actor.emptyBehavior$

Constructor Summary

RemoteDeploymentWatcher()

Method Summary

scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	receive()
scala.collection.immutable.Map<akka.actor.ActorRef,akka.actor.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

akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, 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<akka.actor.ActorRef,akka.actor.InternalActorRef> supervisors()

receive

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

Specified by:

receive in interface akka.actor.Actor