public class RemoteActorRefProvider
extends java.lang.Object
implements akka.actor.ActorRefProvider
ActorRefProvider
interface is supported.
Remote ActorRefProvider. Starts up actor on remote node and creates a RemoteActorRef representing it.
Modifier and Type | Class and Description |
---|---|
static class |
RemoteActorRefProvider.Finished$ |
static class |
RemoteActorRefProvider.Idle$ |
static interface |
RemoteActorRefProvider.TerminatorState |
static class |
RemoteActorRefProvider.Uninitialized$ |
static class |
RemoteActorRefProvider.WaitDaemonShutdown$ |
static class |
RemoteActorRefProvider.WaitTransportShutdown$ |
Constructor and Description |
---|
RemoteActorRefProvider(java.lang.String systemName,
akka.actor.ActorSystem.Settings settings,
akka.event.EventStream eventStream,
akka.actor.DynamicAccess dynamicAccess) |
Modifier and Type | Method and Description |
---|---|
akka.actor.InternalActorRef |
actorFor(akka.actor.ActorPath path) |
akka.actor.InternalActorRef |
actorFor(akka.actor.InternalActorRef ref,
scala.collection.Iterable<java.lang.String> path) |
akka.actor.InternalActorRef |
actorFor(akka.actor.InternalActorRef ref,
java.lang.String path) |
akka.actor.InternalActorRef |
actorOf(akka.actor.ActorSystemImpl system,
akka.actor.Props props,
akka.actor.InternalActorRef supervisor,
akka.actor.ActorPath path,
boolean systemService,
scala.Option<akka.actor.Deploy> deploy,
boolean lookupDeploy,
boolean async) |
protected RemoteDeployer |
createDeployer()
Factory method to make it possible to override deployer in subclass
Creates a new instance every time
|
protected akka.actor.ActorRef |
createRemoteDeploymentWatcher(akka.actor.ActorSystemImpl system) |
protected akka.actor.ActorRef |
createRemoteWatcher(akka.actor.ActorSystemImpl system) |
protected FailureDetectorRegistry<akka.actor.Address> |
createRemoteWatcherFailureDetector(akka.actor.ExtendedActorSystem system) |
akka.actor.InternalActorRef |
deadLetters() |
akka.actor.Deployer |
deployer() |
akka.actor.DynamicAccess |
dynamicAccess() |
akka.event.EventStream |
eventStream() |
akka.actor.Address |
getDefaultAddress() |
scala.Option<akka.actor.Address> |
getExternalAddressFor(akka.actor.Address addr) |
akka.actor.LocalActorRef |
guardian() |
void |
init(akka.actor.ActorSystemImpl system) |
akka.event.LoggingAdapter |
log() |
void |
quarantine(akka.actor.Address address,
scala.Option<java.lang.Object> uid)
Marks a remote system as out of sync and prevents reconnects until the quarantine timeout elapses.
|
void |
registerTempActor(akka.actor.InternalActorRef actorRef,
akka.actor.ActorPath path) |
akka.actor.InternalActorRef |
remoteDaemon() |
RemoteSettings |
remoteSettings() |
akka.actor.ActorRef |
remoteWatcher() |
akka.actor.ActorRef |
resolveActorRef(akka.actor.ActorPath path) |
akka.actor.ActorRef |
resolveActorRef(java.lang.String path) |
akka.actor.InternalActorRef |
resolveActorRefWithLocalAddress(java.lang.String path,
akka.actor.Address localAddress)
INTERNAL API
Called in deserialization of incoming remote messages where the correct local address is known.
|
akka.actor.InternalActorRef |
rootGuardian() |
akka.actor.ActorRef |
rootGuardianAt(akka.actor.Address address) |
akka.actor.ActorPath |
rootPath() |
akka.serialization.Serialization |
serialization() |
akka.actor.ActorSystem.Settings |
settings() |
akka.actor.LocalActorRef |
systemGuardian() |
java.lang.String |
systemName() |
akka.actor.VirtualPathContainer |
tempContainer() |
akka.actor.ActorPath |
tempPath() |
scala.concurrent.Future<akka.actor.Terminated> |
terminationFuture() |
RemoteTransport |
transport() |
void |
unregisterTempActor(akka.actor.ActorPath path) |
void |
useActorOnNode(akka.actor.ActorRef ref,
akka.actor.Props props,
akka.actor.Deploy deploy,
akka.actor.ActorRef supervisor)
Using (checking out) actor on a specific node.
|
public RemoteActorRefProvider(java.lang.String systemName, akka.actor.ActorSystem.Settings settings, akka.event.EventStream eventStream, akka.actor.DynamicAccess dynamicAccess)
public java.lang.String systemName()
public akka.actor.ActorSystem.Settings settings()
settings
in interface akka.actor.ActorRefProvider
public akka.event.EventStream eventStream()
public akka.actor.DynamicAccess dynamicAccess()
public RemoteSettings remoteSettings()
public akka.actor.Deployer deployer()
deployer
in interface akka.actor.ActorRefProvider
protected RemoteDeployer createDeployer()
public akka.event.LoggingAdapter log()
public akka.actor.ActorPath rootPath()
rootPath
in interface akka.actor.ActorRefProvider
public akka.actor.InternalActorRef deadLetters()
deadLetters
in interface akka.actor.ActorRefProvider
public akka.actor.InternalActorRef rootGuardian()
rootGuardian
in interface akka.actor.ActorRefProvider
public akka.actor.LocalActorRef guardian()
guardian
in interface akka.actor.ActorRefProvider
public akka.actor.LocalActorRef systemGuardian()
systemGuardian
in interface akka.actor.ActorRefProvider
public scala.concurrent.Future<akka.actor.Terminated> terminationFuture()
terminationFuture
in interface akka.actor.ActorRefProvider
public void registerTempActor(akka.actor.InternalActorRef actorRef, akka.actor.ActorPath path)
registerTempActor
in interface akka.actor.ActorRefProvider
public void unregisterTempActor(akka.actor.ActorPath path)
unregisterTempActor
in interface akka.actor.ActorRefProvider
public akka.actor.ActorPath tempPath()
tempPath
in interface akka.actor.ActorRefProvider
public akka.actor.VirtualPathContainer tempContainer()
tempContainer
in interface akka.actor.ActorRefProvider
public RemoteTransport transport()
public akka.serialization.Serialization serialization()
public akka.actor.InternalActorRef remoteDaemon()
public akka.actor.ActorRef remoteWatcher()
public void init(akka.actor.ActorSystemImpl system)
init
in interface akka.actor.ActorRefProvider
protected akka.actor.ActorRef createRemoteWatcher(akka.actor.ActorSystemImpl system)
protected FailureDetectorRegistry<akka.actor.Address> createRemoteWatcherFailureDetector(akka.actor.ExtendedActorSystem system)
protected akka.actor.ActorRef createRemoteDeploymentWatcher(akka.actor.ActorSystemImpl system)
public akka.actor.InternalActorRef actorOf(akka.actor.ActorSystemImpl system, akka.actor.Props props, akka.actor.InternalActorRef supervisor, akka.actor.ActorPath path, boolean systemService, scala.Option<akka.actor.Deploy> deploy, boolean lookupDeploy, boolean async)
actorOf
in interface akka.actor.ActorRefProvider
public akka.actor.InternalActorRef actorFor(akka.actor.ActorPath path)
actorFor
in interface akka.actor.ActorRefProvider
public akka.actor.InternalActorRef actorFor(akka.actor.InternalActorRef ref, java.lang.String path)
actorFor
in interface akka.actor.ActorRefProvider
public akka.actor.InternalActorRef actorFor(akka.actor.InternalActorRef ref, scala.collection.Iterable<java.lang.String> path)
actorFor
in interface akka.actor.ActorRefProvider
public akka.actor.ActorRef rootGuardianAt(akka.actor.Address address)
rootGuardianAt
in interface akka.actor.ActorRefProvider
public akka.actor.InternalActorRef resolveActorRefWithLocalAddress(java.lang.String path, akka.actor.Address localAddress)
path
- (undocumented)localAddress
- (undocumented)public akka.actor.ActorRef resolveActorRef(java.lang.String path)
resolveActorRef
in interface akka.actor.ActorRefProvider
public akka.actor.ActorRef resolveActorRef(akka.actor.ActorPath path)
resolveActorRef
in interface akka.actor.ActorRefProvider
public void useActorOnNode(akka.actor.ActorRef ref, akka.actor.Props props, akka.actor.Deploy deploy, akka.actor.ActorRef supervisor)
ref
- (undocumented)props
- (undocumented)deploy
- (undocumented)supervisor
- (undocumented)public scala.Option<akka.actor.Address> getExternalAddressFor(akka.actor.Address addr)
getExternalAddressFor
in interface akka.actor.ActorRefProvider
public akka.actor.Address getDefaultAddress()
getDefaultAddress
in interface akka.actor.ActorRefProvider
public void quarantine(akka.actor.Address address, scala.Option<java.lang.Object> uid)
address
- Address of the remote system to be quarantineduid
- UID of the remote system, if the uid is not defined it will not be a strong quarantine but
the current endpoint writer will be stopped (dropping system messages) and the address will be gated