public interface ReceivePipeline
extends akka.actor.Actor
Modifier and Type | Interface and Description |
---|---|
static interface |
ReceivePipeline.Delegation
Result returned by an interceptor PF to determine what/whether to delegate to the next inner interceptor
|
static class |
ReceivePipeline.Done$ |
static class |
ReceivePipeline.HandledCompletely$
Interceptor return value that indicates that the message has been handled
completely.
|
static interface |
ReceivePipeline.HandlerResult |
static class |
ReceivePipeline.Inner |
static class |
ReceivePipeline.Inner$ |
static class |
ReceivePipeline.InnerAndAfter |
static class |
ReceivePipeline.InnerAndAfter$ |
static class |
ReceivePipeline.Undefined$ |
Modifier and Type | Method and Description |
---|---|
void |
aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive,
java.lang.Object msg)
INTERNAL API.
|
scala.Function1<scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>,scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>> |
combinedDecorator() |
scala.Option<scala.Tuple2<scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>,scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>>> |
decoratorCache() |
scala.collection.immutable.Vector<scala.PartialFunction<java.lang.Object,ReceivePipeline.Delegation>> |
pipeline() |
void |
pipelineInner(scala.PartialFunction<java.lang.Object,ReceivePipeline.Delegation> interceptor)
Adds an inner interceptor, it will be applied lastly, near to Actor's original behavior
|
void |
pipelineOuter(scala.PartialFunction<java.lang.Object,ReceivePipeline.Delegation> interceptor)
Adds an outer interceptor, it will be applied firstly, far from Actor's original behavior
|
java.lang.Object |
toReceive(scala.Function1<java.lang.Object,ReceivePipeline.HandlerResult> handler) |
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, context, postRestart, postStop, preRestart, preStart, receive, self, sender, supervisorStrategy, unhandled
scala.collection.immutable.Vector<scala.PartialFunction<java.lang.Object,ReceivePipeline.Delegation>> pipeline()
scala.Option<scala.Tuple2<scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>,scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>>> decoratorCache()
void pipelineInner(scala.PartialFunction<java.lang.Object,ReceivePipeline.Delegation> interceptor)
interceptor
- an interceptorvoid pipelineOuter(scala.PartialFunction<java.lang.Object,ReceivePipeline.Delegation> interceptor)
interceptor
- an interceptorscala.Function1<scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>,scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>> combinedDecorator()
java.lang.Object toReceive(scala.Function1<java.lang.Object,ReceivePipeline.HandlerResult> handler)
void aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive, java.lang.Object msg)
aroundReceive
in interface akka.actor.Actor
receive
- (undocumented)msg
- (undocumented)