public class ClusterActorRefProvider
extends akka.remote.RemoteActorRefProvider
The ClusterActorRefProvider
will load the Cluster
extension, i.e. the cluster will automatically be started when
the ClusterActorRefProvider
is used.
akka.remote.RemoteActorRefProvider.Finished$, akka.remote.RemoteActorRefProvider.Idle$, akka.remote.RemoteActorRefProvider.Internals, akka.remote.RemoteActorRefProvider.Internals$, akka.remote.RemoteActorRefProvider.RemoteDeadLetterActorRef, akka.remote.RemoteActorRefProvider.RemotingTerminator, akka.remote.RemoteActorRefProvider.TerminatorState, akka.remote.RemoteActorRefProvider.Uninitialized$, akka.remote.RemoteActorRefProvider.WaitDaemonShutdown$, akka.remote.RemoteActorRefProvider.WaitTransportShutdown$
Constructor and Description |
---|
ClusterActorRefProvider(java.lang.String _systemName,
akka.actor.ActorSystem.Settings _settings,
akka.event.EventStream _eventStream,
akka.actor.DynamicAccess _dynamicAccess) |
Modifier and Type | Method and Description |
---|---|
protected ClusterDeployer |
createDeployer()
Factory method to make it possible to override deployer in subclass
Creates a new instance every time
|
protected akka.actor.ActorRef |
createRemoteWatcher(akka.actor.ActorSystemImpl system) |
void |
init(akka.actor.ActorSystemImpl system) |
actorFor, actorFor, actorFor, actorOf, akka$remote$RemoteActorRefProvider$$createFailureDetector$1, createRemoteDeploymentWatcher, createRemoteWatcherFailureDetector, deadLetters, deployer, dynamicAccess, eventStream, getDefaultAddress, getExternalAddressFor, guardian, log, quarantine, registerTempActor, remoteDaemon, remoteSettings, remoteWatcher, resolveActorRef, resolveActorRef, resolveActorRefWithLocalAddress, rootGuardian, rootGuardianAt, rootPath, serialization, settings, systemGuardian, systemName, tempContainer, tempPath, terminationFuture, transport, unregisterTempActor, useActorOnNode
public ClusterActorRefProvider(java.lang.String _systemName, akka.actor.ActorSystem.Settings _settings, akka.event.EventStream _eventStream, akka.actor.DynamicAccess _dynamicAccess)
public void init(akka.actor.ActorSystemImpl system)
init
in interface akka.actor.ActorRefProvider
init
in class akka.remote.RemoteActorRefProvider
protected akka.actor.ActorRef createRemoteWatcher(akka.actor.ActorSystemImpl system)
createRemoteWatcher
in class akka.remote.RemoteActorRefProvider
protected ClusterDeployer createDeployer()
createDeployer
in class akka.remote.RemoteActorRefProvider