Package org.apache.flink.runtime.rpc.pekko

Class RobustActorSystem

java.lang.Object

org.apache.pekko.actor.ActorSystem

org.apache.pekko.actor.ExtendedActorSystem

org.apache.pekko.actor.ActorSystemImpl

org.apache.flink.runtime.rpc.pekko.RobustActorSystem

All Implemented Interfaces:

org.apache.pekko.actor.ActorRefFactory, org.apache.pekko.actor.ClassicActorSystemProvider

public abstract class RobustActorSystem
extends org.apache.pekko.actor.ActorSystemImpl

ActorSystemImpl} which has a configurable Thread.UncaughtExceptionHandler.

The class is abstract because instances need to override ActorSystemImpl.uncaughtExceptionHandler(), as this method is called from the super constructor.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.pekko.actor.ActorSystemImpl

org.apache.pekko.actor.ActorSystemImpl.TerminationCallbacks<T extends Object>

Nested classes/interfaces inherited from class org.apache.pekko.actor.ActorSystem

org.apache.pekko.actor.ActorSystem.Settings, org.apache.pekko.actor.ActorSystem.Settings$

Field Summary

Fields inherited from class org.apache.pekko.actor.ActorSystemImpl

org$apache$pekko$actor$ActorSystemImpl$$markerLogging

Constructor Summary

Constructors

Constructor	Description
RobustActorSystem(String name, com.typesafe.config.Config applicationConfig, ClassLoader classLoader, scala.Option<scala.concurrent.ExecutionContext> defaultExecutionContext, org.apache.pekko.actor.setup.ActorSystemSetup setup)

Method Summary

Modifier and Type	Method	Description
static RobustActorSystem	create(String name, com.typesafe.config.Config applicationConfig)

Methods inherited from class org.apache.pekko.actor.ActorSystemImpl

$div, $div, abort, aborting, aborting_$eq, actorOf, actorOf, assertInitialized, classicSystem, createDynamicAccess, createScheduler, deadLetters, dispatcher, dispatchers, dynamicAccess, eventStream, extension, finalTerminate, getWhenTerminated, guardian, guardianProps, hasExtension, isTerminating, log, logConfiguration, logFilter, lookupRoot, mailboxes, name, printTree, provider, registerExtension, registerOnTermination, registerOnTermination, scheduler, settings, start, stop, stopScheduler, systemActorOf, systemGuardian, systemImpl, terminate, threadFactory, toString, uid, uncaughtExceptionHandler, whenTerminated

Methods inherited from class org.apache.pekko.actor.ActorSystem

actorSelection, actorSelection, apply, apply, apply, apply, apply, apply, apply, apply$default$2, apply$default$3, apply$default$4, child, create, create, create, create, create, create, descendant, getDispatcher, getEventStream, getScheduler, startTime, uptime, Version

Methods inherited from class java.lang.Object

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

Constructor Detail

RobustActorSystem

public RobustActorSystem(String name,
                         com.typesafe.config.Config applicationConfig,
                         ClassLoader classLoader,
                         scala.Option<scala.concurrent.ExecutionContext> defaultExecutionContext,
                         org.apache.pekko.actor.setup.ActorSystemSetup setup)

Method Detail

create

public static RobustActorSystem create(String name,
                                       com.typesafe.config.Config applicationConfig)