akka.typed.internal

Class ActorSystemImpl<T>

java.lang.Object

akka.typed.ActorRef<T>

akka.typed.internal.ActorSystemImpl<T>

All Implemented Interfaces:

ActorSystem<T>, ActorRefImpl<T>, java.lang.Comparable<ActorRef<scala.runtime.Nothing$>>

public class ActorSystemImpl<T>
extends ActorRef<T>
implements ActorSystem<T>, ActorRefImpl<T>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ActorSystemImpl.CreateSystemActor<T>
static class	ActorSystemImpl.CreateSystemActor$
static interface	ActorSystemImpl.SystemCommand

Constructor Summary

Constructors

Constructor and Description
ActorSystemImpl(java.lang.String name, com.typesafe.config.Config _config, java.lang.ClassLoader _cl, scala.Option<scala.concurrent.ExecutionContext> _ec, Behavior<T> _userGuardianBehavior, DeploymentConfig _userGuardianDeployment)

Method Summary

Modifier and Type	Method and Description
static void	$bang(T msg)
static int	compareTo(ActorRef<scala.runtime.Nothing$> other)
protected Scheduler	createScheduler() Create the scheduler service.
<U> ActorRefImpl<U>	deadLetters() The deadLetter address is a destination that will accept (and discard) every message sent to it.
Dispatchers	dispatchers() Facilities for lookup up thread-pools from configuration.
DynamicAccess	dynamicAccess() ClassLoader wrapper which is used for reflective accesses internally.
static boolean	equals(java.lang.Object that)
EventStreamImpl	eventStream() Main event bus of this actor system, used for example for logging.
scala.concurrent.ExecutionContextExecutor	executionContext() The default thread pool of this ActorSystem, configured with settings in akka.actor.default-dispatcher.
static int	hashCode()
boolean	isLocal()
LoggingAdapter	log() A LoggingAdapter that can be used to emit log messages without specifying a more detailed source.
void	logConfiguration() Log the configuration.
LoggingFilter	logFilter() A reference to this system&rsquo;s logFilter, which filters usage of the ActorSystem.log() LoggingAdapter such that only permissible messages are sent via the ActorSystem.eventStream().
int	loggerId()
java.lang.String	name() The name of this actor system, used to distinguish multiple ones within the same JVM & class loader.
static ActorPath	path()
java.lang.String	printTree() Create a string representation of the actor hierarchy within this system.
Scheduler	scheduler() A generic scheduler that can initiate the execution of tasks after some delay.
void	sendSystem(SystemMessage msg)
Settings	settings() The core settings extracted from the supplied configuration.
long	startTime() Start-up time in milliseconds since the epoch.
<U> scala.concurrent.Future<ActorRef<U>>	systemActorOf(Behavior<U> behavior, java.lang.String name, DeploymentConfig deployment, Timeout timeout) Ask the system guardian of this system to create an actor from the given behavior and deployment and with the given name.
static <U> DeploymentConfig	systemActorOf$default$3()
static Behavior<ActorSystemImpl.SystemCommand>	systemGuardianBehavior()
void	tell(T msg) Send a message to the Actor referenced by this ActorRef using *at-most-once* messaging semantics.
scala.concurrent.Future<Terminated>	terminate() Terminates this actor system.
MonitorableThreadFactory	threadFactory() A ThreadFactory that can be used if the transport needs to create any Threads
static java.lang.String	toString()
protected java.lang.Thread.UncaughtExceptionHandler	uncaughtExceptionHandler()
static <U> ActorRef<U>	upcast()
long	uptime() Up-time of this actor system in seconds.
scala.concurrent.Future<Terminated>	whenTerminated() Returns a Future which will be completed after the ActorSystem has been terminated and termination hooks have been executed.

Methods inherited from class akka.typed.ActorRef

apply, apply, compareTo, equals, FunctionPath, FuturePath, hashCode, path, toString, upcast

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

ActorSystemImpl

public ActorSystemImpl(java.lang.String name,
                       com.typesafe.config.Config _config,
                       java.lang.ClassLoader _cl,
                       scala.Option<scala.concurrent.ExecutionContext> _ec,
                       Behavior<T> _userGuardianBehavior,
                       DeploymentConfig _userGuardianDeployment)

Method Detail

systemGuardianBehavior

public static Behavior<ActorSystemImpl.SystemCommand> systemGuardianBehavior()

$bang

public static void $bang(T msg)

upcast

public static <U> ActorRef<U> upcast()

path

public static final ActorPath path()

compareTo

public static final int compareTo(ActorRef<scala.runtime.Nothing$> other)

hashCode

public static final int hashCode()

equals

public static final boolean equals(java.lang.Object that)

toString

public static final java.lang.String toString()

systemActorOf$default$3

public static <U> DeploymentConfig systemActorOf$default$3()

name

public java.lang.String name()

Description copied from interface: ActorSystem

The name of this actor system, used to distinguish multiple ones within the same JVM & class loader.

Specified by:

name in interface ActorSystem<T>

Returns:

(undocumented)

settings

public Settings settings()

Description copied from interface: ActorSystem

The core settings extracted from the supplied configuration.

Specified by:

settings in interface ActorSystem<T>

Returns:

(undocumented)

logConfiguration

public void logConfiguration()

Description copied from interface: ActorSystem

Log the configuration.

Specified by:

logConfiguration in interface ActorSystem<T>

uncaughtExceptionHandler

protected java.lang.Thread.UncaughtExceptionHandler uncaughtExceptionHandler()

threadFactory

public MonitorableThreadFactory threadFactory()

Description copied from interface: ActorSystem

A ThreadFactory that can be used if the transport needs to create any Threads

Specified by:

threadFactory in interface ActorSystem<T>

Returns:

(undocumented)

dynamicAccess

public DynamicAccess dynamicAccess()

Description copied from interface: ActorSystem

ClassLoader wrapper which is used for reflective accesses internally. This is set to use the context class loader, if one is set, or the class loader which loaded the ActorSystem implementation. The context class loader is also set on all threads created by the ActorSystem, if one was set during creation.

Specified by:

dynamicAccess in interface ActorSystem<T>

Returns:

(undocumented)

loggerId

public int loggerId()

eventStream

public EventStreamImpl eventStream()

Description copied from interface: ActorSystem

Main event bus of this actor system, used for example for logging.

Specified by:

eventStream in interface ActorSystem<T>

Returns:

(undocumented)

logFilter

public LoggingFilter logFilter()

Description copied from interface: ActorSystem

A reference to this system&rsquo;s logFilter, which filters usage of the ActorSystem.log() LoggingAdapter such that only permissible messages are sent via the ActorSystem.eventStream(). The default implementation will just test that the message is suitable for the current log level.

Specified by:

logFilter in interface ActorSystem<T>

Returns:

(undocumented)

log

public LoggingAdapter log()

Description copied from interface: ActorSystem

A LoggingAdapter that can be used to emit log messages without specifying a more detailed source. Typically it is desirable to construct a dedicated LoggingAdapter within each Actor from that Actor&rsquo;s ActorRef in order to identify the log messages.

Specified by:

log in interface ActorSystem<T>

Returns:

(undocumented)

createScheduler

protected Scheduler createScheduler()

Create the scheduler service. This one needs one special behavior: if Closeable, it MUST execute all outstanding tasks upon .close() in order to properly shutdown all dispatchers.

Furthermore, this timer service MUST throw IllegalStateException if it cannot schedule a task. Once scheduled, the task MUST be executed. If executed upon close(), the task may execute before its timeout.

Returns:

(undocumented)

scheduler

public Scheduler scheduler()

Description copied from interface: ActorSystem

A generic scheduler that can initiate the execution of tasks after some delay. It is recommended to use the ActorContext&rsquo;s scheduling capabilities for sending messages to actors instead of registering a Runnable for execution using this facility.

Specified by:

scheduler in interface ActorSystem<T>

Returns:

(undocumented)

dispatchers

public Dispatchers dispatchers()

Description copied from interface: ActorSystem

Facilities for lookup up thread-pools from configuration.

Specified by:

dispatchers in interface ActorSystem<T>

Returns:

(undocumented)

executionContext

public scala.concurrent.ExecutionContextExecutor executionContext()

Description copied from interface: ActorSystem

The default thread pool of this ActorSystem, configured with settings in akka.actor.default-dispatcher.

Specified by:

executionContext in interface ActorSystem<T>

Returns:

(undocumented)

startTime

public long startTime()

Description copied from interface: ActorSystem

Start-up time in milliseconds since the epoch.

Specified by:

startTime in interface ActorSystem<T>

Returns:

(undocumented)

uptime

public long uptime()

Description copied from interface: ActorSystem

Up-time of this actor system in seconds.

Specified by:

uptime in interface ActorSystem<T>

Returns:

(undocumented)

terminate

public scala.concurrent.Future<Terminated> terminate()

Description copied from interface: ActorSystem

Terminates this actor system. This will stop the guardian actor, which in turn will recursively stop all its child actors, then the system guardian (below which the logging actors reside).

Specified by:

terminate in interface ActorSystem<T>

Returns:

(undocumented)

whenTerminated

public scala.concurrent.Future<Terminated> whenTerminated()

Description copied from interface: ActorSystem

Returns a Future which will be completed after the ActorSystem has been terminated and termination hooks have been executed.

Specified by:

whenTerminated in interface ActorSystem<T>

Returns:

(undocumented)

deadLetters

public <U> ActorRefImpl<U> deadLetters()

Description copied from interface: ActorSystem

The deadLetter address is a destination that will accept (and discard) every message sent to it.

Specified by:

deadLetters in interface ActorSystem<T>

Returns:

(undocumented)

tell

public void tell(T msg)

Description copied from class: ActorRef

Send a message to the Actor referenced by this ActorRef using *at-most-once* messaging semantics.

Specified by:

tell in class ActorRef<T>

Parameters:

msg - (undocumented)

sendSystem

public void sendSystem(SystemMessage msg)

Specified by:

sendSystem in interface ActorRefImpl<T>

isLocal

public boolean isLocal()

Specified by:

isLocal in interface ActorRefImpl<T>

systemActorOf

public <U> scala.concurrent.Future<ActorRef<U>> systemActorOf(Behavior<U> behavior,
                                                              java.lang.String name,
                                                              DeploymentConfig deployment,
                                                              Timeout timeout)

Description copied from interface: ActorSystem

Ask the system guardian of this system to create an actor from the given behavior and deployment and with the given name. The name does not need to be unique since the guardian will prefix it with a running number when creating the child actor. The timeout sets the timeout used for the AskPattern$ invocation when asking the guardian.

The returned Future of ActorRef may be converted into an ActorRef to which messages can immediately be sent by using the ActorRef$apply method.

Specified by:

systemActorOf in interface ActorSystem<T>

Parameters:

behavior - (undocumented)

name - (undocumented)

deployment - (undocumented)

timeout - (undocumented)

Returns:

(undocumented)

printTree

public java.lang.String printTree()

Description copied from interface: ActorSystem

Create a string representation of the actor hierarchy within this system.

The format of the string is subject to change, i.e. no stable &ldquo;API&rdquo;.

Specified by:

printTree in interface ActorSystem<T>

Returns:

(undocumented)