public class CamelSupervisor extends java.lang.Object implements Actor, CamelSupport
Modifier and Type | Class and Description |
---|---|
static class |
CamelSupervisor.AddWatch
INTERNAL API
Adds a watch for the actor
|
static class |
CamelSupervisor.AddWatch$ |
static class |
CamelSupervisor.CamelProducerObjects
INTERNAL API
Provides a Producer with the required camel objects to function.
|
static class |
CamelSupervisor.CamelProducerObjects$ |
static interface |
CamelSupervisor.CamelSupervisorMessage |
static class |
CamelSupervisor.DeRegister
INTERNAL API
De-registers a producer or a consumer.
|
static class |
CamelSupervisor.DeRegister$ |
static class |
CamelSupervisor.Register
INTERNAL API
Registers a consumer or a producer.
|
static class |
CamelSupervisor.Register$ |
Actor.emptyBehavior$, Actor.ignoringBehavior$
Constructor and Description |
---|
CamelSupervisor() |
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 abstract static void |
akka$camel$CamelSupport$_setter_$camel_$eq(Camel 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) |
protected Camel |
camel()
INTERNAL API
Returns a
Camel trait which provides access to the CamelExtension. |
protected static org.apache.camel.impl.DefaultCamelContext |
camelContext() |
ActorContext |
context()
Stores the context for this actor, including self, and sender.
|
static void |
postRestart(java.lang.Throwable reason) |
static void |
postStop() |
static void |
preRestart(java.lang.Throwable reason,
scala.Option<java.lang.Object> message) |
static void |
preStart() |
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() |
OneForOneStrategy |
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, postStop, preRestart, preStart, sender, unhandled
camelContext
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 postStop() 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)
protected static org.apache.camel.impl.DefaultCamelContext camelContext()
protected abstract static void akka$camel$CamelSupport$_setter_$camel_$eq(Camel x$1)
protected Camel camel()
CamelSupport
Camel
trait which provides access to the CamelExtension.camel
in interface CamelSupport
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 OneForOneStrategy supervisorStrategy()
Actor
supervisorStrategy
in interface Actor