Modifier and Type | Class and Description |
---|---|
static class |
StreamSupervisor.Children
Testing purpose
|
static class |
StreamSupervisor.Children$ |
static class |
StreamSupervisor.GetChildren$
Testing purpose
|
static class |
StreamSupervisor.Materialize |
static class |
StreamSupervisor.Materialize$ |
static class |
StreamSupervisor.PrintDebugDump$
Testing purpose
|
static class |
StreamSupervisor.StopChildren$
Testing purpose
|
static class |
StreamSupervisor.StoppedChildren$
Testing purpose
|
Actor.emptyBehavior$, Actor.ignoringBehavior$
Constructor and Description |
---|
StreamSupervisor(ActorMaterializerSettings settings,
java.util.concurrent.atomic.AtomicBoolean haveShutDown) |
Modifier and Type | Method and Description |
---|---|
protected abstract static void |
akka$actor$Actor$_setter_$context_$eq(ActorContext x$1) |
protected abstract static void |
akka$actor$Actor$_setter_$self_$eq(ActorRef x$1) |
protected static void |
aroundPostRestart(java.lang.Throwable reason) |
protected static void |
aroundPostStop() |
protected static void |
aroundPreRestart(java.lang.Throwable reason,
scala.Option<java.lang.Object> message) |
protected static void |
aroundPreStart() |
protected static void |
aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive,
java.lang.Object msg) |
static java.lang.String |
baseName() |
ActorContext |
context()
Stores the context for this actor, including self, and sender.
|
static java.lang.String |
nextName() |
static void |
postRestart(java.lang.Throwable reason) |
void |
postStop()
User overridable callback.
|
static void |
preRestart(java.lang.Throwable reason,
scala.Option<java.lang.Object> message) |
static void |
preStart() |
static Props |
props(ActorMaterializerSettings settings,
java.util.concurrent.atomic.AtomicBoolean haveShutDown) |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive()
This defines the initial actor behavior, it must return a partial function
with the actor logic.
|
ActorRef |
self()
The 'self' field holds the ActorRef for this actor.
|
static ActorRef |
sender() |
SupervisorStrategy |
supervisorStrategy()
User overridable definition the strategy to use for supervising
child actors.
|
static void |
unhandled(java.lang.Object message) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, postRestart, preRestart, preStart, sender, unhandled
public StreamSupervisor(ActorMaterializerSettings settings, java.util.concurrent.atomic.AtomicBoolean haveShutDown)
public static Props props(ActorMaterializerSettings settings, java.util.concurrent.atomic.AtomicBoolean haveShutDown)
public static java.lang.String baseName()
public static java.lang.String nextName()
public static final ActorRef sender()
protected static void aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive, java.lang.Object msg)
protected static void aroundPreStart()
protected static void aroundPostStop()
protected static void aroundPreRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message)
protected static void aroundPostRestart(java.lang.Throwable reason)
public static void preStart() throws java.lang.Exception
java.lang.Exception
public static void preRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message) throws java.lang.Exception
java.lang.Exception
public static void postRestart(java.lang.Throwable reason) throws java.lang.Exception
java.lang.Exception
public static void unhandled(java.lang.Object message)
protected abstract static void akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
protected abstract static void akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)
public ActorContext context()
Actor
forward
.
WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!
ActorContext
is the Scala API. getContext
returns a
UntypedActorContext
, which is the Java API of the actor
context.
public final ActorRef self()
Actor
self ! message
public SupervisorStrategy supervisorStrategy()
Actor
supervisorStrategy
in interface Actor
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
Actor