|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object akka.actor.LocalActorRefProvider
public class LocalActorRefProvider
Local ActorRef provider.
INTERNAL API!
Depending on this class is not supported, only the ActorRefProvider
interface is supported.
Constructor Summary | |
---|---|
LocalActorRefProvider(java.lang.String _systemName,
ActorSystem.Settings settings,
EventStream eventStream,
Scheduler scheduler,
DynamicAccess dynamicAccess)
|
|
LocalActorRefProvider(java.lang.String _systemName,
ActorSystem.Settings settings,
EventStream eventStream,
Scheduler scheduler,
DynamicAccess dynamicAccess,
akka.actor.Deployer deployer)
|
Method Summary | |
---|---|
akka.actor.InternalActorRef |
actorFor(ActorPath path)
Create actor reference for a specified local or remote path. |
akka.actor.InternalActorRef |
actorFor(akka.actor.InternalActorRef ref,
scala.collection.Iterable<java.lang.String> path)
Create actor reference for the specified child path starting at the given starting point. |
akka.actor.InternalActorRef |
actorFor(akka.actor.InternalActorRef ref,
java.lang.String path)
Create actor reference for a specified local or remote path, which will be parsed using java.net.URI. |
akka.actor.InternalActorRef |
actorOf(akka.actor.ActorSystemImpl system,
Props props,
akka.actor.InternalActorRef supervisor,
ActorPath path,
boolean systemService,
scala.Option<Deploy> deploy,
boolean lookupDeploy,
boolean async)
Actor factory with create-only semantics: will create an actor as described by props with the given supervisor and path (may be different in case of remote supervision). |
akka.actor.InternalActorRef |
deadLetters()
Dead letter destination for this provider. |
akka.actor.Deployer |
deployer()
The Deployer associated with this ActorRefProvider |
MessageDispatcher |
dispatcher()
|
DynamicAccess |
dynamicAccess()
|
EventStream |
eventStream()
|
Address |
getDefaultAddress()
Obtain the external address of the default transport. |
scala.Option<Address> |
getExternalAddressFor(Address addr)
Obtain the address which is to be used within sender references when sending to the given other address or none if the other address cannot be reached from this system (i.e. no means of communication known; no attempt is made to verify actual reachability). |
akka.actor.LocalActorRef |
guardian()
Reference to the supervisor used for all top-level user actors. |
protected SupervisorStrategy |
guardianStrategy()
Overridable supervision strategy to be used by the “/user” guardian. |
void |
init(akka.actor.ActorSystemImpl _system)
Initialization of an ActorRefProvider happens in two steps: first construction of the object with settings, eventStream, scheduler, etc. |
LoggingAdapter |
log()
|
void |
registerExtraNames(scala.collection.immutable.Map<java.lang.String,akka.actor.InternalActorRef> _extras)
Higher-level providers (or extensions) might want to register new synthetic top-level paths for doing special stuff. |
void |
registerTempActor(akka.actor.InternalActorRef actorRef,
ActorPath path)
Registers an actorRef at a path returned by tempPath(); do NOT pass in any other path. |
akka.actor.LocalActorRef |
rootGuardian()
Reference to the supervisor of guardian and systemGuardian; this is exposed so that the ActorSystemImpl can use it as lookupRoot, i.e. |
protected SupervisorStrategy |
rootGuardianStrategy()
Overridable supervision strategy to be used by the “/user” guardian. |
ActorPath |
rootPath()
The root path for all actors within this actor system, not including any remote address information. |
Scheduler |
scheduler()
|
ActorSystem.Settings |
settings()
The Settings associated with this ActorRefProvider |
akka.actor.LocalActorRef |
systemGuardian()
Reference to the supervisor used for all top-level system actors. |
protected SupervisorStrategy |
systemGuardianStrategy()
Overridable supervision strategy to be used by the “/user” guardian. |
akka.actor.VirtualPathContainer |
tempContainer()
Returns the actor reference representing the “/temp” path. |
ActorPath |
tempPath()
Generates and returns a unique actor path below “/temp”. |
scala.concurrent.Future<scala.runtime.BoxedUnit> |
terminationFuture()
This Future is completed upon termination of this ActorRefProvider, which is usually initiated by stopping the guardian via ActorSystem.stop(). |
scala.concurrent.Promise<scala.runtime.BoxedUnit> |
terminationPromise()
|
akka.actor.InternalActorRef |
theOneWhoWalksTheBubblesOfSpaceTime()
Top-level anchor for the supervision hierarchy of this actor system. |
void |
unregisterTempActor(ActorPath path)
Unregister a temporary actor from the “/temp” path (i.e. obtained from tempPath()); do NOT pass in any other path. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public LocalActorRefProvider(java.lang.String _systemName, ActorSystem.Settings settings, EventStream eventStream, Scheduler scheduler, DynamicAccess dynamicAccess, akka.actor.Deployer deployer)
public LocalActorRefProvider(java.lang.String _systemName, ActorSystem.Settings settings, EventStream eventStream, Scheduler scheduler, DynamicAccess dynamicAccess)
Method Detail |
---|
public ActorSystem.Settings settings()
ActorRefProvider
settings
in interface ActorRefProvider
public EventStream eventStream()
public Scheduler scheduler()
scheduler
in interface ActorRefProvider
public DynamicAccess dynamicAccess()
public akka.actor.Deployer deployer()
ActorRefProvider
deployer
in interface ActorRefProvider
public ActorPath rootPath()
ActorRefProvider
rootPath
in interface ActorRefProvider
public LoggingAdapter log()
public akka.actor.InternalActorRef deadLetters()
ActorRefProvider
deadLetters
in interface ActorRefProvider
public ActorPath tempPath()
ActorRefProvider
tempPath
in interface ActorRefProvider
public akka.actor.InternalActorRef theOneWhoWalksTheBubblesOfSpaceTime()
public MessageDispatcher dispatcher()
dispatcher
in interface ActorRefProvider
public scala.concurrent.Promise<scala.runtime.BoxedUnit> terminationPromise()
public scala.concurrent.Future<scala.runtime.BoxedUnit> terminationFuture()
ActorRefProvider
terminationFuture
in interface ActorRefProvider
public void registerExtraNames(scala.collection.immutable.Map<java.lang.String,akka.actor.InternalActorRef> _extras)
protected SupervisorStrategy rootGuardianStrategy()
protected SupervisorStrategy guardianStrategy()
protected SupervisorStrategy systemGuardianStrategy()
public akka.actor.LocalActorRef rootGuardian()
ActorRefProvider
rootGuardian
in interface ActorRefProvider
public akka.actor.LocalActorRef guardian()
ActorRefProvider
guardian
in interface ActorRefProvider
public akka.actor.LocalActorRef systemGuardian()
ActorRefProvider
systemGuardian
in interface ActorRefProvider
public akka.actor.VirtualPathContainer tempContainer()
ActorRefProvider
tempContainer
in interface ActorRefProvider
public void registerTempActor(akka.actor.InternalActorRef actorRef, ActorPath path)
ActorRefProvider
registerTempActor
in interface ActorRefProvider
public void unregisterTempActor(ActorPath path)
ActorRefProvider
unregisterTempActor
in interface ActorRefProvider
public void init(akka.actor.ActorSystemImpl _system)
ActorRefProvider
init
in interface ActorRefProvider
public akka.actor.InternalActorRef actorFor(akka.actor.InternalActorRef ref, java.lang.String path)
ActorRefProvider
s
is a relative URI, resolve
it relative to the given ref.
actorFor
in interface ActorRefProvider
public akka.actor.InternalActorRef actorFor(ActorPath path)
ActorRefProvider
actorFor
in interface ActorRefProvider
public akka.actor.InternalActorRef actorFor(akka.actor.InternalActorRef ref, scala.collection.Iterable<java.lang.String> path)
ActorRefProvider
actorFor
in interface ActorRefProvider
public akka.actor.InternalActorRef actorOf(akka.actor.ActorSystemImpl system, Props props, akka.actor.InternalActorRef supervisor, ActorPath path, boolean systemService, scala.Option<Deploy> deploy, boolean lookupDeploy, boolean async)
ActorRefProvider
Some(deploy)
is passed in, it should be
regarded as taking precedence over the nominally applicable settings,
but it should be overridable from external configuration; the lookup of
the latter can be suppressed by setting
lookupDeploy
to
false
.
actorOf
in interface ActorRefProvider
public scala.Option<Address> getExternalAddressFor(Address addr)
ActorRefProvider
getExternalAddressFor
in interface ActorRefProvider
public Address getDefaultAddress()
ActorRefProvider
getDefaultAddress
in interface ActorRefProvider
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |