akka.cluster
Class ClusterActorRefProvider

java.lang.Object
  akka.remote.RemoteActorRefProvider
      akka.cluster.ClusterActorRefProvider

All Implemented Interfaces:

ActorRefProvider

public class ClusterActorRefProvider
extends RemoteActorRefProvider

INTERNAL API

The ClusterActorRefProvider will load the Cluster extension, i.e. the cluster will automatically be started when the ClusterActorRefProvider is used.

Constructor Summary

ClusterActorRefProvider(java.lang.String _systemName, ActorSystem.Settings _settings, EventStream _eventStream, Scheduler _scheduler, DynamicAccess _dynamicAccess)

Method Summary

protected akka.cluster.ClusterDeployer	createDeployer() Factory method to make it possible to override deployer in subclass Creates a new instance every time
void	init(akka.actor.ActorSystemImpl system) Initialization of an ActorRefProvider happens in two steps: first construction of the object with settings, eventStream, scheduler, etc.
void	useActorOnNode(ActorPath path, Props props, Deploy deploy, ActorRef supervisor) This method is overridden here to keep track of remote deployed actors to be able to clean up corresponding child references.

Methods inherited from class akka.remote.RemoteActorRefProvider

actorFor, actorFor, actorFor, actorOf, deadLetters, deployer, dispatcher, dynamicAccess, eventStream, getDefaultAddress, getExternalAddressFor, guardian, log, registerTempActor, remoteDaemon, remoteSettings, rootGuardian, rootPath, scheduler, serialization, settings, systemGuardian, systemName, tempContainer, tempPath, terminationFuture, transport, unregisterTempActor

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterActorRefProvider

public ClusterActorRefProvider(java.lang.String _systemName,
                               ActorSystem.Settings _settings,
                               EventStream _eventStream,
                               Scheduler _scheduler,
                               DynamicAccess _dynamicAccess)

Method Detail

init

public void init(akka.actor.ActorSystemImpl system)

Description copied from interface: ActorRefProvider

Initialization of an ActorRefProvider happens in two steps: first construction of the object with settings, eventStream, scheduler, etc. and then—when the ActorSystem is constructed—the second phase during which actors may be created (e.g. the guardians).

Specified by:

init in interface ActorRefProvider

Overrides:

init in class RemoteActorRefProvider

createDeployer

protected akka.cluster.ClusterDeployer createDeployer()

Factory method to make it possible to override deployer in subclass Creates a new instance every time

useActorOnNode

public void useActorOnNode(ActorPath path,
                           Props props,
                           Deploy deploy,
                           ActorRef supervisor)

This method is overridden here to keep track of remote deployed actors to be able to clean up corresponding child references.

Overrides:

useActorOnNode in class RemoteActorRefProvider